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).
SeekToCurrentErrorHandlercan 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
@KafkaListenerannotations can now override the container factory’s