Spring for Apache Kafka 1.1 GA 與 Spring Integration Kafka 2.1 GA 現已推出
我很高興宣布 Spring for Apache Kafka 1.1.0.RELEASE 現已在 spring release repo 和 Maven Central 上提供。
由於某些社群需求,我們決定繞過候選發布 (RC) 階段,並立即發布正式版本 (GA)。
自先前的 里程碑 2 以來,沒有太多變更,但以下是所有 Spring Kafka 1.1 變更的摘要
-
Apache Kafka
0.10
升級; -
透過
BatchMessageListener
以及透過@KafkaListener
註解組態支援批次訊息; -
透過
KafkaNull
佔位符物件支援null payload
概念; -
您現在可以從接聽程式執行 seek 作業 - 這允許在使用群組管理時,Kafka 分配分割區時設定初始偏移量。您也可以在初始化後執行任意 seek 作業;
-
允許將初始偏移量設定為相對於目前偏移量;
-
…KafkaTemplate
現在提供對Producer
上的metrics
和partitionsFor
方法的存取權。