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

这其中包含一些错误修复和以下新功能：

• 使用@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 版本。它也支持批量有效负载。

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