kafka-python
kafka-python copied to clipboard
KAFKA-4160: Ensure rebalance listener not called with coordinator lock
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.
Any reason not to merge @dpkp ?
This should not be merged until locking / deadlock issues are addressed. At least it should be rebased onto master after latest lock changes, and then I think we need to look closely at the ensure_active_group changes to make sure locks are maintained.