Found https://issues.apache.org/jira/browse/FLINK-22766
From: Alexey Trenikhun
Sent: Tuesday, May 25, 2021 3:25 PM
To: Ardhani Narasimha ; 陳樺威
; Flink User Mail List
Subject: Re: KafkaSource metrics
Looks like when KafkaSource is used instead of
Looks like when KafkaSource is used instead of FlinkKafkaConsumer, metrics
listed below are not available. Bug? Work in progress?
Thanks,
Alexey
From: Ardhani Narasimha
Sent: Monday, May 24, 2021 9:08 AM
To: 陳樺威
Cc: user
Subject: Re: KafkaSource metrics
Use
fference.
> > On Mon, May 24, 2021 at 7:44 PM 陳樺威 wrote:
> > > Hello,
> > >
> > > Our team tries to test reactive mode and replace FlinkKafkaConsumer with
> > > the new KafkaSource.
> > > But we can’t find the KafkaSource metrics list. Does anyone have any
&
ve mode and replace FlinkKafkaConsumer with
>> the new KafkaSource.
>> But we can’t find the KafkaSource metrics list. Does anyone have any
>> idea? In our case, we want
mode makes any difference.
On Mon, May 24, 2021 at 7:44 PM 陳樺威 wrote:
> Hello,
>
> Our team tries to test reactive mode and replace FlinkKafkaConsumer with
> the new KafkaSource.
> But we can’t find the KafkaSource metrics list. Does anyone have any idea?
> In our case, we want
Hello,
Our team tries to test reactive mode and replace FlinkKafkaConsumer with
the new KafkaSource.
But we can’t find the KafkaSource metrics list. Does anyone have any idea?
In our case, we want to know the Kafka consume delay and consume rate.
Thanks,
Oscar
