我很高兴地宣布 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 的构件可在 Milestone 仓库中找到。

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

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

以异步跟踪发布到 Kafka 主题。

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

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

Spring Integration Kafka 支持

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

下一步

• Spring Boot Kafka 启动器和自动配置正在进行中。
• 为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！

项目页面 | 文档 | 帮助