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 也已发布，包含重要的 bug 修复。请参阅下文了解有关 spring-integration-kafka 3.0.0.RELEASE 的信息。建议所有用户升级。
2.1 版本的主要目的是将 kafka-clients 库升级到 1.0.0，但我们也加入了一些改进。
-
有时，当消息无法处理时，您可能希望停止容器以便纠正情况并重新投递消息。框架现在为记录监听器提供
ContainerStoppingErrorHandler，为批处理监听器提供ContainerStoppingBatchErrorHandler。 -
KafkaAdmin现在支持在检测到NewTopicbean 的分区数量大于主题当前存在的分区数量时增加分区。 -
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…
