Skip to content

KAFKA-4160: Ensure rebalance listener not called with coordinator lock #164

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 114 commits into
base: master
Choose a base branch
from

Conversation

wbarnha
Copy link
Collaborator

@wbarnha wbarnha commented Mar 10, 2024

See https://issues.apache.org/jira/browse/KAFKA-4160 . The original fix was intended to support rebalance listeners that may run longer than the session timeout.


This change is Reviewable

dpkp and others added 30 commits January 31, 2025 10:02
This reverts commit a6d0579.
* Drop dist packaging steps and focus instead on testing.
* Merge kafka/java matrix.
* Separate pylint step, ignore errors for now.
* handle artifact downloads; patch libs on install for kafka < 1
* export env vars
* no progressbar for wget
* Add lint: target; call pytest directly in test: recipe
* Use make targets in gh workflow; use java 21; drop java helper script
* add zstandard to requirements-dev
Co-authored-by: micwoj92 <45581170+micwoj92@users.noreply.github.com>
Co-authored-by: Ryar Nyah <ryarnyah@gmail.com>
Co-authored-by: HalfSweet <60973476+HalfSweet@users.noreply.github.com>
Co-authored-by: Denis Otkidach <denis.otkidach@gmail.com>
Co-authored-by: Laityned <d.a.w.markus@student.tue.nl>
Co-authored-by: misha.gavela <Arfey17.mg@gmail.com>
Co-authored-by: Dave Voutila <voutilad@gmail.com>
Co-authored-by: drewdogg <drewdogg@users.noreply.github.com>
Co-authored-by: chopatate <florian.courouge@outlook.fr>
* conn: no connection delays between dns entries; merge blacked_out w/ connection_delay
* conn: next_ifr_request_timeout_ms() returns delay until next req timeout
* Drop poll timeout reset when no in flight requests
* Do not mark conn as sending if future immediately resolves (error)
* client poll: do not set 100ms timeout for unfinished futures
* Improve metadata refresh backoff/retry -- respect connection delays
* conn: honor reconnect backoff in connection_delay when connecting
* Log connection delay for not-ready nodes in producer sender loop
* Increase default reconnect_backoff_max_ms to 30000 (30 secs)
dpkp and others added 28 commits March 6, 2025 07:29
Co-authored-by: Matt Oberle <mattoberle@users.noreply.github.com>
Co-authored-by: Emmanuel <manuco@users.noreply.github.com>
@dpkp dpkp force-pushed the KAFKA_4160_rebalance_listener_without_lock branch from 159f5a3 to 0ed425c Compare March 13, 2025 15:14
@dpkp dpkp deleted the KAFKA_4160_rebalance_listener_without_lock branch March 13, 2025 15:22
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

5 participants