HI Team, I am using flink 1.15.2 with kafka source...
# troubleshooting
n
HI Team, I am using flink 1.15.2 with kafka source and kafka sink. I am getting below exception and flink is keep on retrying the same events, what is the cause I am not able to find it.
Copy code
WARN org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher [] - Committing offsets to Kafka failed. This does not compromise Flink's checkpoints.
org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset commit failed with a retriable exception. You should retry committing the latest consumed offsets.Caused by: org.apache.kafka.common.errors.CoordinatorNotAvailableException: The coordinator is not available.
m
That’s usually that the Flink machines can’t access the Kafka brokers. Either a networking or an authentication issue
✅ 1