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’s concurrency and autoStartup properties

• The new ErrorhandlingDeserializer can catch deserialization exceptions which are then routed to the ErrorHandler

• 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