Spring for Apache Kafka 2.3 Milestone 2
We are pleased to announce the availability of the second milestone of the Spring for Apache Kafka 2.3 release - 2.3.0.M2.
Highlights
-
SeekToCurrentErrorHandler
can be configured to not retry certain exceptions. -
The new
RecoveringDeserializationExceptionHandler
can recover from failed deserialization operations in Kafka Streams applications, for example to send the failed message to a dead-letter topic. -
The new
HeaderEnricher
transformer can be added to a Kafka Streams topology to add headers. -
The new
MessagingTransformer
can be used to invoke a Spring Integration flow within a Kafka Streams topology. -
The new
AggregatingReplyingKafkaTemplate
can send a record and wait for responses from multiple consumers. …