Releases: meitu/go-consumergroup
Releases · meitu/go-consumergroup
v0.2.5
v0.2.3: Merge pull request #35 from meitu/fix/rebalance_bug
- fix rebalance bug, the consumer would be pending while the partition consumer failed to exit the claim function
- supports GetOffsets/OnLoad/OnClose callback API
v0.2.2
0.2.1
Refactor consumer group
- Refactor consumer group log message
- Add more annotation
- Refactor GetTopicNextMessageChannel => GetMessages, GetTopicErrorsChannel
=> GetErrors - Refactor consumer-group into topic-consumer and partition-consumer
init version
Merge pull request #8 from Huang-lin/master FIX:sort consumer list to prevent data conflict