v0.15.0

horkhe released this 30 Mar 08:49

· 94 commits to master since this release

f2aace6

Implemented:

#135 Added support for Kafka v0.11.0.0 - v1.0.0
consumer.rebalance_timeout was removed, so rebalancing is triggered as soon as membership status of a consumer group or subscription of a consumer group member changes.
#138 Pending offsets are committed to Kafka faster on rebalancing. That could take up to consumer.offsets_commit_interval before, but now it happens as soon as possible.

Fixed:

#120 Consumption from atopic stopped for a group.
#123 Inexplicable offset manager timeouts.
#124 Subscription to a topic fails indefinitely after ZooKeeper connection loss.
#140 Offset manager keeps losing connection with a broker.

Assets 4