v2.4.7

What's Changed

• feat: increase batch performance by @Abdulsametileri in #156
• feat: implement prometheus metrics as atomic in order to solve data race by @berruk in #161
• feat: remove spaces from broker lists implementation by @osemrt in #151
• feat: throw panic when produce message to retry topic is unsuccessful by @pinarrkok in #150
• feat: verifyTopicOnStartup field true as default by @kutay-o in #162
• chore: Update debezium/zookeeper image version by @ibrahimkarahan47 in #157

New Contributors

• @berruk made their first contribution in #159
• @pinarrkok made their first contribution in #150
• @osemrt made their first contribution in #151
• @kutay-o made their first contribution in #162
• @ibrahimkarahan47 made their first contribution in #157
  Full Changelog: v2.4.6...v2.4.7

v2.4.6

What's Changed

• fix: disable singleton kafka client by @BurakG01 in #148

When the VerifyTopicOnStartup flag is enabled (true), the consumer checks whether the topic exists, the authorization process is okay, etc.

When multiple consumer integration, internal once.Do implementation causes a bug, this release fixes this issue.

Full Changelog: v2.3.6...v2.4.6

v2.3.6

What's Changed

• feat: introduce retry configuration concurrency by @Abdulsametileri in #146
• feat: cronsumer internal queue capacity, producer batch size and timeout expose by @Abdulsametileri in #147

Full Changelog: v2.3.5...v2.3.6

v2.3.5

What's Changed

• feat: add producer interceptor interface by @ademekici in #145

Full Changelog: v2.3.4...v2.3.5

v2.3.4

What's Changed

• feat: provide message group limit default by @Abdulsametileri in #134
• feat: disable instant retry for non transactional retry mode by @Abdulsametileri in #136
• feat: change skip message log level to debug and add Pretty for writing headers by @Abdulsametileri in #137
• feat: enhance Message Could Not Reader error by adding topic and cg info by @Abdulsametileri in #138
• feat: wrap kafka client with sync once for support singleton by @Abdulsametileri in #139
• feat: write json and string methods for producer and consumer configs… by @oktaykcr in #141
• feat: bump kafka-cronsumer v1.5.4 by @ugurcanerdogan @ademekici in #142

Full Changelog: v2.3.3...v2.3.4

v2.3.3

What's Changed

• feat: add batch byte size limit configuration by @mhmtszr in #129
• feat: added topic exists check (#59) by @Abdulsametileri and @keremcankabadayi in #131
• feat: expose error metric when fetching message by @Abdulsametileri in #132
• feat: run integration tests in parallel by @ademekici in #126
• feature/use-retry-brokers-for-retry-producer use retry brokers when p… by @ErenArslan in #130

New Contributors

• @ErenArslan made their first contribution in #130

Full Changelog: v2.3.2...v2.3.3

v2.3.2

What's Changed

• feat: make Pause and Resume methods idempotent by @Abdulsametileri in #124

Full Changelog: v2.3.1...v2.3.2

v2.3.1

What's Changed

• feat: fix security vuln CVE-2024-25124 by @emretanriverdi in #112
• fix: Transactional Retry false x-error-message bug by @Abdulsametileri in #122
• feat: enable balancer support to the retry configuration by @dilaragorum in #123

New Contributors

• @emretanriverdi made their first contribution in #112

Full Changelog: v2.3.0...v2.4.0

v2.3.0

What's Changed

• feat: add metric prefix config and expose metricCollectors by @Abdulsametileri in #106
• feat: bump kafka-cronsumer v1.5.0

Full Changelog: v2.2.9...v2.3.0

v2.2.9

What's Changed

• feat: add skip message by header filter function for cronsumer by @emrekosen in #104
• feat: add header filter feature by @dilaragorum in #105
• docs: Add the default value "MessageGroupDuration" to the README.md by @oktaykcr in #90
• chore: Create SECURITY.md by @ugurcanerdogan in #97

New Contributors

• @oktaykcr made their first contribution in #90
• @emrekosen made their first contribution in #104
• @dilaragorum made their first contribution in #105

Full Changelog: v2.1.9...v2.2.9