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()
等操作。