Flink 1.15消费进度提交失败

问题现象

Flink 1.15版本消费Kafka时， 消费进度提交失败，持续报错：COORDINATOR_NOT_AVAILABLE。

根因描述

Flink 1.15版本使用的Kafka客户端存在bug，当某次消费进度提交失败后， 客户端将coordinator置为不可用且无法自动恢复。

问题解决措施

• 重启Flink job。
• 升级Flink至1.16及以上版本。