Hi John, First I would like to ask you to give us some more information about how you consume from Kafka with Flink. It is currently recommended to use the KafkaSource that subsumes the deprecated FlinkKafkaConsumer.
One thing to already note is that by default Flink does not commit the Kafka to offset back to the topic because it is not needed from a Flink perspective and is only supported on a best-effort basis if a checkpoint completes. I am not very familiar with Kafka Explorer but I can imagine it only shows the consumer group if there are actually committed offsets Best, Fabian On Mon, Jan 31, 2022 at 3:41 PM John Smith <[email protected]> wrote: > > Hi using flink 1.14.3, I have a job that doesn't use checkpointing. I have > noticed that the Kafka Consumer Group is not set? > > I use Kafka Explorer to see all the consumers and when I run the job I don't > see the consumer group. Finally I decided to enable checkpointing and restart > the job and finally saw the consumer group. > > Is this expected behaviour?
