Spring for Apache Kafka 2.2 Released
I am pleased to announce that Spring for Apache Kafka 2.2.0.RELEASE is now available.
While the 2.1.x release is compatible with the 2.0.0 kafka-clients
jar, (since 2.1.9), this version requires 2.0.0 (and provides a 2.0.0 embedded broker for testing).
Highlights
-
The
SeekToCurrentErrorHandler
can now "skip" records that fail repeatedly -
Such "skipped" records can be published to a dead-letter topic (or otherwise disposed of by application code)
-
Headers are added with diagnostics about the failure
-
-
When using transactions, the same functionality can be achieved with the default
AfterRollbackProcessor
-
You can now use the listener container factory to create any arbitrary listener container, not just containers for
@KafkaListener
s-
This allows more convenient use of Spring Boot’s auto configuration properties for any container
-
-
…@KafkaListener
annotations can now override the container factory’sconcurrency
andautoStartup
properties