Skip to content

Connect: Fix coordinator consumer group on iceberg control topic with… - #17350

Open
rainerschamm wants to merge 3 commits into
apache:mainfrom
rainerschamm:coordinator_consumer_group_closing_fix
Open

Connect: Fix coordinator consumer group on iceberg control topic with…#17350
rainerschamm wants to merge 3 commits into
apache:mainfrom
rainerschamm:coordinator_consumer_group_closing_fix

Conversation

@rainerschamm

Copy link
Copy Markdown

@uros-b uros-b left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@rainerschamm This seems to be overlapping with #16843. cc @hkwi

@rainerschamm

Copy link
Copy Markdown
Author

@rainerschamm This seems to be overlapping with #16843. cc @hkwi

Ah yes thanks, there is a bit of overlap.

@hkwi

hkwi commented Jul 25, 2026

Copy link
Copy Markdown

Thank you for reporting this in #17349 and for following up with the fix in
#17350. It looks like we independently ran into the same coordinator shutdown
issue.

I reviewed both #17349 and #17350, and I believe #16843 already covers the
reported failure mode. #16843 makes CoordinatorThread.terminate() wait for
the coordinator thread to exit, so the shutdown path reaches
coordinator.stop() before task shutdown continues. It also checks whether
the thread is still alive after the timeout and propagates interruption or
termination failures.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Kafka Connect: Coord consumer group on iceberg control topic with phantom consumer after stopping a connector

3 participants