VMware offers training and certification to turbo-charge your progress.Learn more
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).
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
You can now use the listener container factory to create any arbitrary listener container, not just containers for
This allows more convenient use of Spring Boot’s auto configuration properties for any container
@KafkaListener annotations can now override the container factory’s
ErrorhandlingDeserializer can catch deserialization exceptions which are then routed to the
The embedded kafka broker can now be used with JUnit 5 tests
For more information see the What’s New chapter in the documentation and the change log.
In addition, Spring Integration for Apache Kafka (
spring-integration-kafka) 3.1.0.RELEASE is available; it is based on Spring for Apache Kafka 2.2 and Spring Integration 5.1.
Project Page | GitHub | Issues | Documentation | Stack Overflow | Gitter