v1.0.8

What's Changed

• change logger level by @askuy in #21
• change logger level by @askuy in #22
• feat(consumer): watchPartitionChanges set default true by @kl7sn in #23

Full Changelog: v1.0.7...v1.0.8

v1.0.7

What's Changed

• fix: consumerserver example 中处理订阅错误 by @jackcipher in #20

New Contributors

• @jackcipher made their first contribution in #20

Full Changelog: v1.0.6...v1.0.7

v1.0.6

What's Changed

• upgrade github.com/segmentio/kafka-go by @askuy in #18

New Contributors

• @askuy made their first contribution in #18

Full Changelog: v1.0.5...v1.0.6

v1.0.5

What's Changed

• fix batch handler timeout by @clannadxr in #17

Full Changelog: v1.0.4...v1.0.5

v1.0.4

v1.0.4

What's Changed

• support batch listener by @clannadxr in #8
• support batch listener by @clannadxr in #9
• 不暴露NewListener by @clannadxr in #10
• batch handler 消息里加上ctx by @clannadxr in #11
• kafka compress by @qingbozhang in #12
• fix sasl panic by @clannadxr in #14
• newBatchListener auto commit by @sevennt in #15
• Feat poll add ctx by @clannadxr in #13
• set default debug to false by @sevennt in #16

New Contributors

• @qingbozhang made their first contribution in #12

Full Changelog: v1.0.3...v1.0.4

v1.0.3

What's Changed

• add topic to accessClientInterceptor by @sevennt in #5
• kafka handler 里 message 改成指针 by @clannadxr in #6
• consumer 退出时继续提交未提交的消息 by @clannadxr in #7

New Contributors

• @sevennt made their first contribution in #5

Full Changelog: v1.0.2...v1.0.3

v1.0.2

What's Changed

• feat: 同步gotomicro ekafka变更 by @kl7sn in #2
• 支持不提交消息 & kafka 错误时，不退出 consumer server by @clannadxr in #3
• remove consumptionErrors by @clannadxr in #4

New Contributors

• @kl7sn made their first contribution in #2
• @clannadxr made their first contribution in #3

Full Changelog: v1.0.1...v1.0.2

v1.0.1

Full Changelog: v1.0.0...v1.0.1

v1.0.0

Full Changelog: https://github.com/ego-component/ekafka/commits/v1.0.0