Micronaut Kafka 5.4.0

What's Changed

Other Changes 💡

• Testcontainers via test-resources version catalog by @wetted in #964
• Add executor configuration for KafkaClient by @jeremyg484 in #955
• Allow reactive consumer methods with error strategy by @jeremyg484 in #977
• Add option to customise close() wait (fixes #901) by @agarciadom in #902

Improvements ⭐

• Add RETRY_CONDITIONALLY_ON_ERROR and RETRY_CONDITIONALLY_EXPONENTIALLY_ON_ERROR KafkaListener error strategies to conditionally retry messages by @MRyanEvans in #946

Dependency updates 🚀

• fix(deps): update dependency org.apache.kafka:kafka-clients to v3.7.0 by @renovate in #971
• fix(deps): update dependency io.zipkin.brave:brave-instrumentation-kafka-clients to v6.0.2 by @renovate in #966
• fix(deps): update managed.kafka to v3.7.0 by @renovate in #973
• fix(deps): update dependency org.awaitility:awaitility to v4.2.1 by @renovate in #992

Kotlin

• chore(deps): update kotlin monorepo to v1.9.23 by @renovate in #978
• fix(deps): update dependency org.jetbrains.kotlinx:kotlinx-coroutines-core to v1.8.0 by @renovate in #968

Micronaut Modules

Micronaut Core

• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.3.9 by @renovate in #959
• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.3.10 by @renovate in #979
• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.3.12 by @renovate in #990
• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.4.0 by @renovate in #1001
• fix(deps): update dependency micronaut to v4.3.4 by @renovate in #953
• fix(deps): update dependency micronaut to v4.3.5 by @renovate in #981
• fix(deps): update dependency micronaut to v4.3.7 by @renovate in #991

Micronaut Platform

• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.3.4 by @renovate in #951
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.3.5 by @renovate in #980
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.3.7 by @renovate in #989

Micronaut Serialization

• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.8.1 by @renovate in #950
• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.8.2 by @renovate in #985

Micronaut Reactor

• fix(deps): update dependency io.micronaut.reactor:micronaut-reactor-bom to v3.3.0 by @renovate in #1002

Micronaut Cache

• fix(deps): update dependency io.micronaut.cache:micronaut-cache-bom to v4.2.2 by @renovate in #944

Micronaut Tracing

• fix(deps): update dependency io.micronaut.tracing:micronaut-tracing-bom to v6.4.1 by @renovate in #948

Micronaut Micrometer

• fix(deps): update dependency io.micronaut.micrometer:micronaut-micrometer-bom to v5.4.0 by @renovate in #949

Micronaut Logging

Micronaut Test Resources

• fix(deps): update dependency io.micronaut.testresources:micronaut-test-resources-bom to v2.3.3 by @renovate in #965
• fix(deps): update dependency io.micronaut.testresources:micronaut-test-resources-bom to v2.4.0 by @renovate in #976

CI ⚙️Build 🐘

• chore(deps): update gradle/gradle-build-action action to v2.12.0 by @renovate in #958
• chore(deps): update gradle/wrapper-validation-action action to v2 by @renovate in #962
• chore(deps): update dependency gradle to v8.7 by @renovate in #997

GraalVM

• chore(deps): update dependency org.graalvm.sdk:graal-sdk to v23.1.2 by @renovate in #945

• chore(deps): update graalvm/setup-graalvm action to v1.1.8 by @renovate in #957

• chore(deps): update graalvm/setup-graalvm action to v1.1.9 by @renovate in #984

• chore(deps): update graalvm/setup-graalvm action to v1.2.1 by @renovate in #993

Junit Report

SLSA

• chore(deps): update slsa-framework/slsa-github-generator action to v1.10.0 by @renovate in #999

Micronaut Build Plugin

• chore(deps): update plugin io.micronaut.build.shared.settings to v6.6.2 by @renovate in #943
• chore(deps): update plugin io.micronaut.build.shared.settings to v6.6.4 by @renovate in #974
• chore(deps): update plugin io.micronaut.build.shared.settings to v6.7.0 by @renovate in #987

Micronaut Gradle Plugin

• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.3.3 by @renovate in #963
• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.3.4 by @renovate in #975
• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.3.5 by @renovate in #996

New Contributors

• @MRyanEvans made their first contribution in #946
• @agarciadom made their first contribution in #902

Full Changelog: v5.3.0...v5.4.0

Micronaut Kafka 4.5.5

What's Changed

• Support to infer deserializers correctly batch listeners recieving ConsumerRecords (#598)

Full Changelog: v4.5.4...v4.5.5

Micronaut Kafka 5.3.0

What's Changed

Other Changes 💡

• Support for ConsumerRecords container type on batch processing by @rorueda in #904
• fix: kafka health indicator requires kafka configuration by @rorueda in #937

Docs 📖

• Add links to guides for Micronaut Kafka by @wetted in #936

Dependency updates 🚀

Kafka

• fix(deps): update managed.kafka to v3.6.1 by @renovate in #935
• fix(deps): update dependency org.apache.kafka:kafka-clients to v3.6.1 by @renovate in #934

brave-instrumentation-kafka-clients

• fix(deps): update dependency io.zipkin.brave:brave-instrumentation-kafka-clients to v6 by @renovate in #941
• fix(deps): update dependency io.zipkin.brave:brave-instrumentation-kafka-clients to v5.18.1 by @renovate in #939

TestContainers

• fix(deps): update dependency org.testcontainers:kafka to v1.19.3 by @renovate in #924

Kotlin

• chore(deps): update kotlin monorepo to v1.9.22 by @renovate in #932

Micronaut Modules

Micronaut Core

• fix(deps): update dependency micronaut to v4.2.3 by @renovate in #940
• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.2.3 by @renovate in #927

Micronaut Platform

• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.2.3 by @renovate in #926

Micronaut Serialization

• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.3.3 - autoclosed by @renovate in #918
• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.7.0 by @renovate in #922

Micronaut Cache

• fix(deps): update dependency io.micronaut.cache:micronaut-cache-bom to v4.1.2 by @renovate in #938

Micronaut Micrometer

• fix(deps): update dependency io.micronaut.micrometer:micronaut-micrometer-bom to v5.1.2 by @renovate in #920
• fix(deps): update dependency io.micronaut.micrometer:micronaut-micrometer-bom to v5.2.0 by @renovate in #925

Micronaut Tracing

• fix(deps): update dependency io.micronaut.tracing:micronaut-tracing-bom to v6.2.0 by @renovate in #921

Micronaut Reactor

• fix(deps): update dependency io.micronaut.reactor:micronaut-reactor-bom to v3.2.1 by @renovate in #931

CI ⚙️Build 🐘

Micronaut Build Plugin

• chore(deps): update plugin io.micronaut.build.shared.settings to v6.6.1 by @renovate in #919

Micronaut Gradle Plugin

• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.2.1 by @renovate in #923

New Contributors

• @rorueda made their first contribution in #904

Full Changelog: v5.2.0...v5.3.0

Micronaut Kafka 5.2.0

What's Changed

New Features 🎉

• Auto-create topic with N partitions by @guillermocalvo in #879
• Add support for batch error strategy by @guillermocalvo in #890

Other Changes 💡

• Suspend @KafkaListener functions by @hanahavlova in #874

Bug Fixes 🐞

• Honor transactionalId when a Kafka producer bean is injected by @guillermocalvo in #865
• Normalize producer client ID to find configuration bean by @guillermocalvo in #878
• Normalize consumer group ID to find configuration bean by @guillermocalvo in #876
• Remove annotation @Internal from class JsonObjectSerde by @guillermocalvo in #849

Improvements ⭐

• Refactor KafkaConsumerProcessor by @guillermocalvo in #871
• Add support for batch Acknowledgement by @guillermocalvo in #887

Docs 📖

• Fix missing end::clazz tags by @guillermocalvo in #886
• Transactional Kafka Producer per thread by @guillermocalvo in #882

Dependency updates 🚀

• fix(deps): update managed.kafka to v3.6.0 by @renovate in #914
• fix(deps): update dependency org.apache.kafka:kafka-clients to v3.6.0 by @renovate in #913
• Update versions by @sdelamo in #884

Testcontainers Kafka

• fix(deps): update dependency org.testcontainers:kafka to v1.19.1 by @renovate in #888

Kotlin

• chore(deps): update kotlin to v1.9.20 by @renovate in #908
• fix(deps): update dependency org.jetbrains.kotlinx:kotlinx-coroutines-core to v1.7.3 by @renovate in #907

Micronaut Modules

Micronaut Core

• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.1.5 by @renovate in #868
• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.1.8 by @renovate in #881
• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.1.10 by @renovate in #891
• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.1.11 by @renovate in #909

Micronaut Serialization

• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.2.5 by @renovate in #883
• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.3.2 - autoclosed by @renovate in #906

Micronaut Platform

• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.1.1 by @renovate in #870
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.1.2 by @renovate in #880
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.1.3 by @renovate in #885
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.1.5 by @renovate in #896
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.1.6 by @renovate in #910

Micronaut Tracing

• fix(deps): update dependency io.micronaut.tracing:micronaut-tracing-bom to v6 by @renovate in #915

Micronaut Micrometer

• fix(deps): update dependency io.micronaut.micrometer:micronaut-micrometer-bom to v5.1.1 by @renovate in #917

Micronaut Cache

• fix(deps): update dependency io.micronaut.cache:micronaut-cache-bom to v4.1.1 by @renovate in #911

Micronaut Reactor

• fix(deps): update dependency io.micronaut.reactor:micronaut-reactor-bom to v3.1.0 by @renovate in #900

CI ⚙️Build 🐘

• Gradle Enterprise rename by @timyates in #897
• Fix java 21 by @wetted in #899

GraalVM

• chore(deps): update graalvm/setup-graalvm action to v1.1.4 by @renovate in #875
• chore(deps): update graalvm/setup-graalvm action to v1.1.5 by @renovate in #912

GraalVM SDK

• chore(deps): update dependency org.graalvm.sdk:graal-sdk to v23.1.0 by @renovate in #877
• chore(deps): update dependency org.graalvm.sdk:graal-sdk to v23.1.1 by @renovate in #898

Micronaut Build Plugin

• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.1.1 by @renovate in #872
• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.1.2 by @renovate in #905

New Contributors

• @hanahavlova made their first contribution in #874

Full Changelog: v5.1.2...v5.2.0

Micronaut Kafka 5.1.2

What's Changed

Bug Fixes 🐞

• Prevent consumers with duplicate client IDs from shadowing each other by @guillermocalvo in #864

Dependency updates 🚀

• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.1.3 by @renovate in #861
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.1.0 - autoclosed by @renovate in #862
• chore(deps): update graalvm/setup-graalvm action to v1.1.3 by @renovate in #863
• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.2.4 by @renovate in #858
• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.1.0 by @renovate in #857
• chore(deps): update plugin io.micronaut.build.shared.settings to v6.5.6 by @renovate in #856
• fix(deps): update dependency io.micronaut.tracing:micronaut-tracing-bom to v5.0.2 by @renovate in #859
• chore(deps): update mikepenz/action-junit-report action to v4 by @renovate in #866

Other Changes 💡

• Use kafka metadata from the shared metadata repo by @msupic in #855

Full Changelog: v5.1.1...v5.1.2

Micronaut Kafka 5.1.1

What's Changed

Bug Fixes 🐞

• Remove obsolete bean requirement KafkaHealthIndicator -> AdminClient by @guillermocalvo in #848
• Swallowed exception thrown from custom exception handler -> kafka consumer closed by @guillermocalvo in #854

Docs 📖

• Cleanup docs-examples and builds in test-suite modules by @wetted in #846
• make brand and name not nullable by @sdelamo in #853
• close class in docs by @sdelamo in #852
• use configuration macro by @sdelamo in #851
• use reactor instead of rxjava2 by @sdelamo in #850

Dependency updates 🚀

• fix(deps): update dependency io.micronaut.serde:micronaut-serde-bom to v2.2.1 - autoclosed by @renovate in #847

Full Changelog: v5.1.0...v5.1.1

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

• fix(deps): update dependency io.micronaut:micronaut-core-bom to v4.1.0 by @renovate in #796

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

Micronaut Kafka 5.0.3

What's Changed

Dependency Upgrades 🚀

• fix(deps): update dependency org.apache.kafka:kafka-clients to v3.5.1 (#799)
• fix(deps): update managed.kafka to v3.5.1 (#802)
• fix(deps): update dependency io.micronaut.rxjava2:micronaut-rxjava2-bom to v2.0.1 (#788)
• fix(deps): update dependency io.micronaut.tracing:micronaut-tracing-bom to v5.0.1 (#790)
• fix(deps): update dependency org.testcontainers:kafka to v1.18.3 (#801)

Platform

• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.5 (#840)
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.4 (#823)
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.3 (#806)
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.2 (#797)
• fix(deps): update dependency io.micronaut.platform:micronaut-platform to v4.0.1 (#786)

Reactor

• fix(deps): update dependency io.micronaut.reactor:micronaut-reactor-bom to v3.0.2 (#830)
• fix(deps): update dependency io.micronaut.reactor:micronaut-reactor-bom to v3.0.1 (#787)

CI ⚙️

• Update common files (#805)
• Update common files (#798)
• Update common files (#791)
• Update common files (#785)
• chore(deps): update slsa-framework/slsa-github-generator action to v1.8.0 (#807)
• chore(deps): update graalvm/setup-graalvm action to v1.1.2 (#794)
• chore(deps): update dependency org.graalvm.sdk:graal-sdk to v23.0.1 (#784)

Build 🐘

• chore(deps): update plugin io.micronaut.build.shared.settings to v6.5.5 (#808)
• chore(deps): update plugin io.micronaut.build.shared.settings to v6.5.4 (#800)
• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.0.2 (#795)

Full Changelog: v5.0.2...v5.0.3

Micronaut Kafka 5.0.2

What's Changed

Bug Fixes 🐞

• Catch record deserialization exceptions that may happen while polling by @guillermocalvo in #771

Improvements ⭐

• Replace deprecated method call findArgumentBinder by @guillermocalvo in #772
• Kafka health checks and topics replication by @guillermocalvo in #774

Docs 📖

• Update guide ("Embedding Kafka" -> "Dockerizing Kafka") by @guillermocalvo in #777

Dependency updates 🚀

• fix(deps): update dependency io.micronaut.micrometer:micronaut-micrometer-bom to v5.0.1 by @renovate in #778
• fix(deps): update dependency io.micronaut.cache:micronaut-cache-bom to v4.0.1 by @renovate in #776
• fix(deps): update dependency io.micronaut.gradle:micronaut-gradle-plugin to v4.0.1 by @renovate in #779

Other Changes 💡

• Remove baseline version for binary compatibility check by @wetted in #775

Full Changelog: v5.0.1...v5.0.2

Micronaut Kafka 5.0.1

What's Changed

Dependency updates 🚀

• fix(deps): update dependency io.micronaut.cache:micronaut-cache-bom to v4.0.0 by @renovate in #770
• Kafka no milestones by @sdelamo in #773

Full Changelog: v5.0.0...v5.0.1