Spring for Apache Kafka 2.3 发布
Spring for Apache Kafka 2.3 发布了。Spring for Apache Kafka(spring-kafka)项目将核心 Spring 概念应用于基于 Kafka 的消息传递解决方案。它提供了一个“模板”作为发送消息的高级抽象,还为带有 @KafkaListener 注解和“侦听器容器(listener container)”的消息驱动的 POJO 提供支持。这些库促进了依赖注入和声明的使用。 此版本更新主要内容包括: Producing 在每个线程中可选使用生产者,以避免在刷新时阻塞其它线程。 提供了对 ReplyingKafkaTemplate 的 AggregatingReplyingKafkaTemplate 扩展,以汇总来自多个消费者的回复 Consuming 现在可以在调用侦听器之前添加一个 RecordInterceptor 来修改记录。 ConsumerSeekAware 现在支持相对搜寻。 现在可以指定在处理上一个 poll() 结果与发出下一个 poll() 之间的延迟。 使用手动 AckMode 时,现在可以消极地确认记录,并且容器...