Hi,
I think the preceding message that the consumer is not a member of the
group suggests that there is some connectivity issue.
Perhaps, heartbeats are timing out in which case you might want to
increase session.timeout.ms [1] and heartbeat.interval.ms.
[1]
https://docs.confluent.io/platform/cur
Hi Hemant,
One possible reason is that another Kafka consumer is using the same consumer
group id as the one in FlinkKafkaConsumer. You can try to use another group.id
in FlinkKafkaConsumer to validate this.
If it’s not group id’s problem, there are some Kafka consumer metrics [1] that
might b
Hi,
I am using flink 12.1 to consume data from kafka in a streaming job. Using
the flink-connector-kafka_2.12:1.12.1. Kafka broker version is 2.2.1
In logs I see warnings like this -
2021-08-26 13:36:49,903 WARN
org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher [] -
Committing o
