KafkaTemplate now supports API to add records with timestamps.
New KafkaHeaders have been introduced regarding timestamp support.
Also new KafkaConditions.timestamp() and KafkaMatchers.hasTimestamp() testing utilities have been added.
See the section called “KafkaTemplate”, the section called “@KafkaListener Annotation” and Section 4.3, “Testing Applications” for more details.
You can now configure a KafkaListenerErrorHandler to handle exceptions.
See Section 4.1.5, “Handling Exceptions” for more information.
You can now annotate @KafkaListener methods (and classes, and @KafkaHandler methods) with @SendTo.
If the method returns a result, it is forwarded to the specified topic.
See the section called “Forwarding Listener Results using @SendTo” for more information.
Message listeners can now be aware of the Consumer object.
See the section called “Message Listeners” for more information.
Rebalance listeners can now access the Consumer object during rebalance notifications.
See the section called “Rebalance Listeners” for more information.
For convenience a test class level @EmbeddedKafka annotation is provided with the purpose to register KafkaEmbedded as a bean.
See Section 4.3, “Testing Applications” for more information.
Support for configuring Kerberos is now provided. See Section 4.1.6, “Kerberos” for more information.