我很高興地宣布，Spring for Apache Kafka 1.1.0.M2 的第二個里程碑版本現已在 spring milestone repo 中提供。

此版本包含一些錯誤修復以及以下新功能

• 現在使用 @KafkaListener 註解時，可以使用處理一批訊息的功能（在上一個里程碑中引入），例如…​

  @KafkaListener(id = "list", topics = "myTopic", containerFactory = "batchFactory") public void listen(Listlist) { ... }

• 您現在可以從 listener 執行 seek 操作 - 允許在使用群組管理時，由 Kafka 分配分區時設定初始 offset。 您也可以在初始化後執行任意的 seek 操作。

KafkaTemplate 現在可以存取 Producer 上的 metrics 和 partitionsFor 方法。

此外，spring-integration-kafka 2.1 的第一個里程碑版本現已發布，使用了 spring-kafka 1.1.0.M2 版本。 它也支援批次酬載。

請參閱 專案頁面，以取得文件和更多資訊的連結。