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.
Parent topic: Troubleshooting
- Symptom
- Root Cause
- Solution