Micronaut Kafka 5.1.0
What's Changed
New Features π
- Publish events after Consumer subscribes and after first polling by @jfsanchez91 in #677
- Restrict AdminClient permission for KafkaHealthIndicator by @guillermocalvo in #810
- Missing the ConsumerSeekAware interface by @guillermocalvo in #812
- Support for setting uncaught exception handler by @guillermocalvo in #780
Bug Fixes π
- CI never ends for unit tests with manual test container lifecycle control by @guillermocalvo in #782
Improvements β
- Introduce
ErrorStrategy.retryCountValue
to allow for dynamic config by @guillermocalvo in #789 - Introduce
KafkaListener.threadsValue
to allow for dynamic config by @guillermocalvo in #769 - Decorate user-provided instances of
ProducerRecord
, instead of using them as a raw values by @guillermocalvo in #813 - partial fix for #110, call Deserializer#configure and Serializer#configure by @edeesis in #673
- Avoid log pollution while waiting for consumer to close by @guillermocalvo in #821
- Allow to commit offset in case of deserialization errors by @giamo in #761
Docs π
- Fix outdated documentation for Kafka batch listeners by @guillermocalvo in #814
- Missing @singleton by @agustin-tecso in #633
- Multi-language documentation for fallback example by @wetted in #818
- Multi-language documentation for Committing Offsets Manually with Batch example by @wetted in #820
- Multi-language documentation for Quickstart example by @wetted in #822
- Fixing test-suite docs examples to use test-resources by @wetted in #825
- Multi-language documentation for Declaring KafkaClient Headers example by @wetted in #829
- Multi-language documentation for Injecting Kafka Producer Beans example by @wetted in #826
- Multi-language documentation for Configuring Producer Properties example by @wetted in #828
- Multi-language docs examples for client batch examples (part 2) by @wetted in #834
- Multi-language docs examples for Specifying error strategies by @wetted in #833
- Multi-language docs examples for client configuration and method examples by @wetted in #836
- Multi-language docs examples for Manually Committing Offsets examples by @wetted in #835
- Multi-language docs examples for listener thread configuration by @wetted in #837
- Multi-language documentation for Forwarding Messages with @sendto example by @wetted in #827
- Multi-language documentation for Configuring Consumer examples by @wetted in #832
- Multi-language docs examples for Kafka Streams by @wetted in #839
Dependency updates π
- fix(deps): update dependency io.micronaut.tracing:micronaut-tracing-bom to v5.0.1 by @renovate in #790
- fix(deps): update dependency io.micronaut.rxjava2:micronaut-rxjava2-bom to v2.0.1 - autoclosed by @renovate in #788
- fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.2.0 by @renovate in #804
- fix(deps): update dependency org.apache.kafka:kafka-clients to v3.5.1 by @renovate in #799
- fix(deps): update managed.kafka to v3.5.1 by @renovate in #802
- fix(deps): update dependency io.micronaut.cache:micronaut-cache-bom to v4.0.2 by @renovate in #819
- fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.1.1 by @renovate in #831
- chore(deps): update kotlin monorepo to v1.9.10 by @renovate in #838
- chore(deps): update kotlin monorepo to v1.9.0 by @renovate in #803
TestContainers Kafka
- fix(deps): update dependency org.testcontainers:kafka to v1.19.0 by @renovate in #843
- fix(deps): update dependency org.testcontainers:kafka to v1.18.3 by @renovate in #801
Reactor
- fix(deps): update dependency io.micronaut.reactor:micronaut-reactor-bom to v3.0.2 - autoclosed by @renovate in #830
- fix(deps): update dependency io.micronaut.reactor:micronaut-reactor-bom to v3.0.1 by @renovate in #787
Core
Platform
- fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.5 by @renovate in #840
- fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.4 by @renovate in #823
- fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.3 - autoclosed by @renovate in #806
- fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.2 by @renovate in #797
- fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.1 by @renovate in #786
CI βοΈ
- chore(deps): update dependency org.graalvm.sdk:graal-sdk to v23.0.1 by @renovate in #784
- chore(deps): update slsa-framework/slsa-github-generator action to v1.9.0 by @renovate in #842
- chore(deps): update slsa-framework/slsa-github-generator action to v1.8.0 by @renovate in #807
- chore(deps): update graalvm/setup-graalvm action to v1.1.2 by @renovate in #794
Build π
- fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.0.2 - autoclosed by @renovate in #795
- chore(deps): update plugin io.micronaut.build.shared.settings to v6.5.5 by @renovate in #808
- chore(deps): update plugin io.micronaut.build.shared.settings to v6.5.4 by @renovate in #800
Other Changes π‘
- Safely destructure numerical values when configuring Kafka Metrics by @Hc747 in #809
- Groovify the groovy test-suite by @timyates in #824
- Return ScheduledExecutorService from ConsumerExecutorServiceConfig by @Hc747 in #844
New Contributors
- @jfsanchez91 made their first contribution in #677
- @Hc747 made their first contribution in #809
- @agustin-tecso made their first contribution in #633
- @edeesis made their first contribution in #673
Full Changelog: v5.0.2...v5.1.0