更新时间：2024-11-11 GMT+08:00
Flink 1.15消费进度提交失败
问题现象
Flink 1.15版本消费Kafka时， 消费进度提交失败，持续报错：COORDINATOR_NOT_AVAILABLE。
根因描述
Flink 1.15版本使用的Kafka客户端存在bug，当某次消费进度提交失败后， 客户端将coordinator置为不可用且无法自动恢复。
问题解决措施
- 重启Flink job。
- 升级Flink至1.16及以上版本。
