0.5.2.3

[astubbs]

Improvements

• Transactional commit mode system improvements and docs (Transaction system improvements and docs #355)

  • Clarifies transaction system with much better documentation.
  • Fixes a potential race condition which could cause offset leaks between transactions boundaries.
  • Introduces lock acquisition timeouts.
  • Fixes a potential issue with removing records from the retry queue incorrectly, by having an inconsistency between compareTo and equals in the retry TreeMap.

• Adds a very simple Dependency Injection system modeled on Dagger (Improvements/DI module #398)

• Various refactorings e.g. new ProducerWrap

• Dependencies

  • build(deps): prod: zstd, reactor, dev: podam, progressbar, postgresql maven-plugins: versions, help (build(deps): prod: zstd, reactor, dev: podam, progressbar, postgresql maven-plugins: versions, help #420)
  • build(deps-dev): bump postgresql from 42.4.1 to 42.5.0
  • bump podam, progressbar, zstd, reactor
  • build(deps): bump versions-maven-plugin from 2.11.0 to 2.12.0
  • build(deps): bump maven-help-plugin from 3.2.0 to 3.3.0
  • build(deps-dev): bump Confluent Platform Kafka Broker to 7.2.2 (build(deps-dev): bump Confluent Platform Kafka Broker to 7.2.2 #421)
  • build(deps): Upgrade to AK 3.3.0 (build(deps): Upgrade to AK 3.3.0 #309)

Fixes

• fixes Consumer closes with an exception NoSuchElementException #419: NoSuchElementException during race condition in PartitionState (fixes #419 NoSuchElementException during race condition in PartitionState #422)
• Fixes ClassCastException: io.confluent.parallelconsumer.state.WorkContainer cannot be cast to io.confluent.parallelconsumer.RecordContext #412: ClassCastException with retryDelayProvider (Fixes #412: ClassCastException with retryDelayProvider #417)
• fixes ShardManager retryQueue ordering and set issues due to poor Comparator implementation (fixes ShardManager retryQueue ordering and set issues due to poor Comparator implementation #423)

GH generated:

What's Changed

• Improvements/DI module by @astubbs in Improvements/DI module #398
• Improvements/transaction docs large refactorings Improvements/transaction docs large refactorings #399 - Fix for merge error by @astubbs in Improvements/transaction docs large refactorings #399 - Fix for merge error #406
• Transaction system improvements and docs by @astubbs in Transaction system improvements and docs #355
• build(deps): Upgrade to AK 3.3.0 by @astubbs in build(deps): Upgrade to AK 3.3.0 #309
• build(deps-dev): bump Confluent Platform Kafka Broker to 7.2.2 by @astubbs in build(deps-dev): bump Confluent Platform Kafka Broker to 7.2.2 #421
• build(deps): prod: zstd, reactor, dev: podam, progressbar, postgresql maven-plugins: versions, help by @astubbs in build(deps): prod: zstd, reactor, dev: podam, progressbar, postgresql maven-plugins: versions, help #420
• Fixes ClassCastException: io.confluent.parallelconsumer.state.WorkContainer cannot be cast to io.confluent.parallelconsumer.RecordContext #412: ClassCastException with retryDelayProvider by @astubbs in Fixes #412: ClassCastException with retryDelayProvider #417
• ide: Add in ignored bisect helper and run targets by @astubbs in ide: Add in ignored bisect helper and run targets #347
• fixes Consumer closes with an exception NoSuchElementException #419 NoSuchElementException during race condition in PartitionState by @astubbs in fixes #419 NoSuchElementException during race condition in PartitionState #422
• docs: Clarify offset storage behaviour by @astubbs in docs: Clarify offset storage behaviour #424
• fixes When unexpected magic bytes occur, improve the feedback in the error shown to the user #327: Friendlier error for encoding problems & Exception name normalisation by @astubbs in fixes #327: Friendlier error for encoding problems & Exception name normalisation #354
• fixes ShardManager retryQueue ordering and set issues due to poor Comparator implementation by @astubbs in fixes ShardManager retryQueue ordering and set issues due to poor Comparator implementation #423

Full Changelog: 0.5.2.2...0.5.2.3

---

This discussion was created from the release 0.5.2.3.