Hi Lars, You are likely seeing this Kafka client bug: https://issues.apache.org/jira/browse/KAFKA-13840. The latest versions of Flink have updated Kafka clients dependency to include this fix.
Best, Mason On Thu, Jul 20, 2023 at 9:21 AM Lars Skjærven <lar...@gmail.com> wrote: > Hello, > I experienced > CoordinatorNotAvailableException in my flink jobs after our kafka supplier > (aiven) did a maintenance update of the cluster. This update is performed > by starting up new kafka nodes, copying over data, and switching over > internally. The flink jobs runs as expected, with the only issue that they > are unsuccessful in committing group offsets. > > Restarting the job from checkpoint/savepoint resolves the issue, but I > would rather not restart all jobs after every kafka maintenance update. > > Any ideas ? > > Kind regards, > Lars Skjærven >
