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

这包括一些错误修复和以下新功能

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

有关文档和更多信息的链接，请参见项目页面。