/cc @John Casey - who might be able to help.
On Wed, Jan 18, 2023 at 12:43 PM Lydian wrote:
> Hi,
> I know that Beam KafkaIO doesn't use the native kafka offset, and
> therefore I cannot use kafka metrics directly.
>
> Wondering what would be the right way to expose those metrics of my
> KafkaI
Adding: @Andrew Pilloud @Kenneth Knowles
On Thu, Jan 12, 2023 at 12:31 PM Talat Uyarer via user
wrote:
> Hi All,
>
> I am using Beam 2.43 with Calcite SQL with Java.
>
> I have a query with a WITH clause and some aliasing. Looks like Beam Query
> optimizer after optimizing my query, it drops S
