Spring for Apache Kafka 2.1.0.RELEASE (以及 1.3.2, 2.0.2) 已可用
我很高兴宣布 Spring for Apache Kafka 2.1.0.RELEASE 已发布。
此外,包含重要错误修复的维护版本 1.3.2.RELEASE 和 2.0.2.RELEASE 也已发布。有关 spring-integration-kafka
3.0.0.RELEASE 的信息,请参阅下文。建议所有用户升级。
2.1 版本的主要目的是将 kafka-clients
库升级到 1.0.0,但我们还包含了一些改进。
-
有时,当消息无法处理时,您可能希望停止容器,以便纠正条件并重新投递消息。框架现在为记录监听器提供了
ContainerStoppingErrorHandler
,为批量监听器提供了ContainerStoppingBatchErrorHandler
。 -
当检测到具有比当前主题上存在的分区数量更多的分区的
NewTopic
bean 时,KafkaAdmin
现在支持增加分区。 -
StringJsonMessageConverter
和JsonSerializer/JsonDeserializer
现在在Headers
中传递和使用类型信息。这使得在同一主题上轻松发送/接收多种类型的消息成为可能。@SpringBootApplication public class Kafka21Application {
public static void main(String[] args) { SpringApplication.run(Kafka21Application.class, args) .close(); } @Bean public ApplicationRunner runner(KafkaTemplate<Object, Object> template) { return args -> { template.send(MessageBuilder.withPayload(42) .setHeader(KafkaHeaders.TOPIC, "blog") .build()); template.send(MessageBuilder.withPayload("4…