Consumers running inside Flink cluster not reported

[lilyevsky]

We have consumers that are running inside Flink cluster, using the FlinkKafkaConsumer . They are not reported at all.
I looked into what is different about them. Apparently, those consumers for some reason do not send their client.id to the Kafka broker (I can see that by using Confluent utilities). It is obviously their problem, and maybe they will fix it in the future.
On the other hand, this should not be a reason for not showing their lags at all; the offsets and lags by consumer group and partition are available.

[surajpuvvada]

Hello
I'm having the same issue. None of the flink kafka consumer group lags are being displayed. Is there something I need to do ?

[lilyevsky]

Fixed in 0.6.2