Files
doc-exports/docs/dms/umn/kafka_trouble_0007.html
chenjunjie 190f09501c DMS UMN 20250314 version
Reviewed-by: Liudmila Denisova <ldenisov@noreply.gitea.eco.tsi-dev.otc-service.com>
Co-authored-by: chenjunjie <chenjunjie@huawei.com>
Co-committed-by: chenjunjie <chenjunjie@huawei.com>
2025-10-06 09:50:17 +00:00

1.4 KiB

Flink 1.15 Consumption Progress Submission Failure

Symptom

To consume Kafka messages in Flink 1.15, the consumption progress fails to be submitted, and the error messages "COORDINATOR_NOT_AVAILABLE" are thrown.

Root Cause

Bug on the Kafka client used by Flink 1.15: When the consumption progress fails to be submitted for once, the client sets the coordinator to unavailable and it cannot be automatically restored.

Solution

  • Restart the Flink job.
  • Upgrade Flink to 1.16 or later.