我很高兴地宣布，spring-kafka（用于 Apache Kafka 的 Spring）1.0版本的第二个里程碑版本现已发布。

工件org.springframework.kafka:spring-kafka:1.0.0.M2和org.springframework.kafka:spring-kafka-test:1.0.0.M2可在里程碑存储库中找到。

自第一个里程碑版本以来的更改包括：

• KafkaTemplate.send()方法现在返回ListenableFuture<SendResult<K, V>>

用于异步跟踪发布到 Kafka 主题。

• MessagingMessageListenerAdapter（用于@KafkaListener方法）现在可以根据方法参数推断payload转换的类型。
• 一个StringJsonMessageConverter，它可以使用类型推断来使用Jackson ObjectMapper从JSON内容构建目标对象。
• 已从Listener添加RECEIVED_头，以避免与发送时（例如使用Spring Integration适配器）具有相同messageKey的相同topic发生冲突（重新路由）。
• 更多测试实用程序。

有关更多信息，另请参见参考手册。

Spring Integration Kafka 支持

不要错过Spring Integration Kafka 2.0 的第一个里程碑版本，它完全基于此 Spring for Apache Kafka 基础。

后续步骤

• Spring Boot Kafka 启动器和自动配置正在进行中。
• 针对spring-cloud-stream的新绑定器实现。
• 完善文档，设置项目页面等。

我们还在研究1.1版本，以使用Reactor的Flux和Mono抽象实现与Kafka使用响应式流的交互。同时，Apache Kafka 0.10.0及其Kafka Streams功能，也将是Spring for Apache Kafka 1.1的一个很好的补充。

与此同时，我们期待您的反馈，如果一切顺利，计划在接下来的几周内发布1.0.0.RELEASE！

项目页面 | 文档 | 帮助