Spring for Apache Kafka 2.0 里程碑 1 发布
我们非常高兴地宣布 Spring for Apache Kafka 2.0 版本的第一个里程碑 2.0.0.M1 已发布。
2.0 版本中的重要新功能包括
-
支持
KafkaTemplate
中的时间戳。 -
搜索主题的开头/结尾。
-
由 KIP-62 促进的新线程模型 - 现在消费者客户端不再依赖于频繁调用
poll()
,线程模型变得更加简单;避免了对内部pause()
/resume()
处理的需要。监听器现在始终在消费者线程上调用。反过来,这促进了 -
提供了
…ConsumerAwareMessageListener
(以及BatchConsumerAwareMessageListener
),以便监听器实现可以访问Consumer<?, ?>
对象以执行诸如pause()
、resume()
、metrics()
等操作。