Spring for Apache Kafka 2.2 Released

Releases | Gary Russell | October 29, 2018 | ...

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

Get the Spring newsletter

Stay connected with the Spring newsletter

Subscribe

Get ahead

VMware offers training and certification to turbo-charge your progress.

Learn more

Get support

Tanzu Spring offers support and binaries for OpenJDK™, Spring, and Apache Tomcat® in one simple subscription.

Learn more

Upcoming events

Check out all the upcoming events in the Spring community.

View all