Skip to content

Releases: meitu/go-consumergroup

v0.2.5

26 Nov 02:06
Compare
Choose a tag to compare
FIX: make lint error

v0.2.3: Merge pull request #35 from meitu/fix/rebalance_bug

06 Nov 01:57
4149a4b
Compare
Choose a tag to compare
  • 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

16 Jul 02:30
df041c7
Compare
Choose a tag to compare
  • Supports auto-reset the offset with oldest when the offset was out of range
  • Replace Join/Exit group API with Start/Stop
  • Replace inner logger with logrus, and adjust the log's format
  • Supports user-defined consumer id

0.2.1

22 Mar 05:38
6b39dd8
Compare
Choose a tag to compare
  • Fix the partition offset with the message's offset instead of autoincrementing
  • The partition exited when encountering the recovered error
  • Enable return errors in consumer

Refactor consumer group

26 Jul 07:39
Compare
Choose a tag to compare
  • Refactor consumer group log message
  • Add more annotation
  • Refactor GetTopicNextMessageChannel => GetMessages, GetTopicErrorsChannel
    => GetErrors
  • Refactor consumer-group into topic-consumer and partition-consumer

init version

26 Jul 07:47
Compare
Choose a tag to compare
Merge pull request #8 from Huang-lin/master

FIX:sort consumer list to prevent data conflict