我很高兴地宣布 spring-kafka（Spring for Apache Kafka）版本 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_ 标头，以避免在发送时与相同的 messageKey 冲突（重新路由）到相同的 topic，例如，使用 Spring Integration Adapters。
• 更多测试实用程序。

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

Spring Integration Kafka 支持

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

下一步

• Spring Boot Kafka starter 和 AutoConfiguration 正在 进行中。
• 一个用于 spring-cloud-stream 的新 Binder 实现。
• 充实文档，设置项目页面等。

此外，我们已经在研究版本 1.1，以使用 Reactor 的 Flux 和 Mono 抽象实现与 Reactive Streams 的 Kafka 交互。 同时，Apache Kafka 0.10.0 及其 Kafka Streams 功能，对于 Spring for Apache Kafka 1.1 来说也是一个很好的补充。

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

项目页面 | 文档 | 帮助