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
-
SeekToCurrentErrorHandlercan be configured to not retry certain exceptions. -
The new
RecoveringDeserializationExceptionHandlercan recover from failed deserialization operations in Kafka Streams applications, for example to send the failed message to a dead-letter topic. -
The new
HeaderEnrichertransformer can be added to a Kafka Streams topology to add headers. -
The new
MessagingTransformercan be used to invoke a Spring Integration flow within a Kafka Streams topology. -
The new
AggregatingReplyingKafkaTemplatecan send a record and wait for responses from multiple consumers. …