ping to bump this topic. Can we get some more input here or on the JIRA on the agreement to resolve this issue? Thanks a lot.
Shuyi On Mon, Mar 25, 2019 at 8:43 AM Shuyi Chen <suez1...@gmail.com> wrote: > Thanks a lot, Becket. I am sorry that I was out of the loop for the last > few days due to sickness. Let’s keep the discussion continue on the JIRA. > > Shuyi > > On Mon, Mar 25, 2019 at 4:46 AM Becket Qin <becket....@gmail.com> wrote: > >> Hi Shuyi, >> >> Thanks for bringing this issue up. Per partition lag is definitely >> something that should be exposed. I replied to the JIRA with some of my >> concerns. Do you mind keeping the discussion in the JIRA ticket so it is >> easier for future readers to follow the issue? >> >> Thanks, >> >> Jiangjie (Becket) Qin >> >> On Mon, Mar 18, 2019 at 2:14 PM Shuyi Chen <suez1...@gmail.com> wrote: >> >> > Hi all, >> > >> > We found that Flink's Kafka connector does not expose the per-partition >> > Kafka lag. The metric is available in KafkaConsumer after Kafka 0.10.2. >> And >> > it's an important metric to diagnose which Kafka partition is lagging in >> > production. I've created a JIRA ( >> > https://issues.apache.org/jira/browse/FLINK-11912) and created a >> proposed >> > change in Flink to register and expose the metrics. Could someone help >> take >> > a look and give some suggestions? Thanks a lot. >> > >> > Shuyi >> > >> >
