Spring for Apache Kafka 2.7.0 发布
Spring for Apache Kafka 2.7.0 已经发布,Spring for Apache Kafka 将 Spring 核心概念应用于基于 Kafka 的消息传递解决方案的开发,它提供了一个“模板”作为发送消息的高级抽象。它还通过 @KafkaListener 注解和“侦听器容器(listener container)”为消息驱动的 POJO 提供支持。 主要更新内容 使用 topic 时非阻塞延迟重试。当严格的排序并不重要时,可以将失败的交付发送到另一个 topic 中,以便以后消费。可以配置一系列这样的重试 topic,并增加延迟。 侦听器容器更改。onlyLogRecordMetadata 容器属性现在默认为 true,并且有了一个新的容器属性 stopImmediate。 @KafkaListener 更改。现在,用户可以验证 @KafkaHandler 方法的有效负载参数(类级侦听器),在 MessagingMessageConverter 和 BatchMessagingMessageConverter 上设置 rawRecordHeader 属性,这会将原...