Skip to content

Go Kafka v3
Compare
Choose a tag to compare
@EdouardBavoux EdouardBavoux released this 16 Apr 12:22
· 10 commits to master since this release
v3.0.0
235363c
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Learn about vigilant mode.

Go-kafka V3 allows configuration at topic level, and relies on IBM saram (change of ownership).

What's Changed

  • The library now relies on the IBM/sarama library instead of Shopify/sarama, which is no longer maintained.
  • The kafka.Handler type has been changed to a struct containing both the function to execute and the handler's optional configuration.
  • The global variable PushConsumerErrorsToTopic has been replaced by the PushConsumerErrorsToRetryTopic and PushConsumerErrorsToDeadletterTopic properties on the handler.

These changes should be the only breaking changes in the v3 release. The rest of the library should be compatible with the previous version.

Full Changelog: v2.2.0...v3.0.0

Assets 2
Loading