The work here was concentrated on fixing bugs after the coordination refactors on v0.4.0. Hope it will serve you better now!
Bugfix:
- Added error propagation from coordinator to the main consumer. Before consumer
just stopped with error logged. (issue #294) - Fix manual partition assignment, broken in 0.4.0 (issue #394)
- Fixed RecursionError in MessageAccumulator.add_message (issue #409)
- Update kafka-python to latest 1.4.3 and added support for Python3.7
- Dropped support for Python3.3 and Python3.4
Infrastructure:
- Added Kafka 1.0.2 broker for CI test runner
- Refactored Travis CI build pipeline