我很高兴地宣布 Spring for Apache Kafka 版本 1.1.0.M2 的第二个里程碑版本现已在 spring milestone 仓库中提供。

这包括一些 bug 修复以及以下新功能：

• 使用 @KafkaListener 注解时，现在可以使用处理消息批次的能力（在上一个里程碑中引入），例如……

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

• 您现在可以从监听器执行 seek 操作 - 当 Kafka 在使用组管理时分配分区时，这允许设置一个初始偏移量。您也可以在初始化后执行任意的 seek 操作。

KafkaTemplate 现在提供了对 Producer 的 metrics 和 partitionsFor 方法的访问。

此外，spring-integration-kafka 2.1 版本的第一个里程碑现已发布，它使用了 spring-kafka 1.1.0.M2 版本。它也支持批处理负载。

请参阅 项目页面 以获取文档链接和更多信息。