Skip to content

Releases: Trendyol/kafka-konsumer

v1.2.1

20 Jun 06:16
Compare
Choose a tag to compare

Changelog

  • 4493eb0 feat: client id implementation for producer and consumer (#12)

v1.1.1

16 Jun 10:31
3558156
Compare
Choose a tag to compare

Changelog

  • 3558156 Merge pull request #11 from Trendyol/feature/#7
  • 34130c9 feat: add batch consumer without api and cronsumer
  • cdd3876 fix: concurrency field to sets properly for default case (#9)
  • ca9a916 fix: move processed message counter increase operation after commit
  • 8573729 refactor: batch consumer
  • 1782f12 refactor: change concurrency default value
  • c1c4eb9 refactor: context initialization and kcronsumer config encapsulation, remove unsafe
  • 0fbb7e8 refactor: implement unsafe converting between kafka.Message and kcronsumer.Message
  • bd452c0 refactor: move []subprocess to standalone type
  • 85e7144 refactor: naming errors for check
  • 604c697 refactor: refactor dir and add new metrics
  • 9dce935 refactor: remove NewBatchConsumer

v1.0.0

05 Jun 04:59
Compare
Choose a tag to compare

Changelog

  • ed78e7f feat: upgrade cronsumer and segmentio version

v0.0.7

15 May 12:09
Compare
Choose a tag to compare

Changelog

  • 646dedc feat: add broker field to retry configurations
  • 0910c53 feat: add broker, sasl, tls configuration to retry configuration

v0.0.6

15 May 11:53
Compare
Choose a tag to compare

Changelog

  • 646dedc feat: add broker field to retry configurations
  • 0910c53 feat: add broker, sasl, tls configuration to retry configuration

v0.0.5

08 May 08:04
518c82b
Compare
Choose a tag to compare

Changelog

v0.0.4

25 Apr 14:23
Compare
Choose a tag to compare

Changelog

  • 3ed9a9d feat: pass rack configuration to kafka-cronsumer

v0.0.3

25 Apr 14:07
Compare
Choose a tag to compare

Changelog

  • a4fac27 feat: add kafka rack to consumer configurations

v0.0.2

25 Apr 13:24
d965996
Compare
Choose a tag to compare

Changelog

  • d965996 feat: add manuel commit implementation as default

v0.0.1

23 Apr 09:33
Compare
Choose a tag to compare

Changelog

  • b4dff7a extract functional structure
  • 25c7c8a extract functional structure v2
  • cecbf2b feat: add README
  • 6c014a4 feat: add cronsumer integration and refactor
  • 4946dc8 feat: add examples
  • 3273201 feat: add golangci lint and github actions
  • 1960f79 feat: add goreleaser
  • a75f02d feat: add implementation with kafka-cronsumer
  • ccd7264 feat: add logger and custom logger implementations
  • e8929db feat: add sasl enabled true when initializing cronsumer with sasl
  • 7b596e7 feat: enhance examples
  • d8bd161 feat: initialize structure without kafka-cronsumer
  • 0500cf2 feat: new structure
  • 208af19 feat: tls config change, cronsumer graceful fix, update readme
  • 5b1b169 fix: start cronsumer if retry enabled
  • 64bb5ac refactor: directory structure