我很高兴地宣布 Spring for Apache Kafka 1.0.3 维护版本 现已发布。

与往常一样，感谢社区的所有反馈和贡献！

此版本包含几个重要的错误修复，包括使用手动确认时的内存泄漏；因此强烈建议升级。

解决的问题可以在 这里 找到。

该项目现在可以正确处理带有 null payload 的 kafka 消息，这是在使用 Kafka Log Compaction 时用于“删除”键的常见用例。@KafkaListener 方法现在将收到 null 参数用于此类消息。

spring-messaging（因此 spring-integration-kafka）不支持带有 null payload 的消息。在 spring-integration-kafka (版本 2.0.1) 中，此类消息用类型为 KafkaNull 的 payload 表示 - 有关完整详细信息，请参阅 项目 README。

项目页面 | GitHub | 帮助 | 文档