spring-integration - Kafka 与手动偏移管理 Spring 集成

Question

我是 Kafka 的新手，我正在尝试使用来自 Kafka 的消息，我能够在来自 this 的基本 Kafka spring 集成示例的帮助下做到这一点。

现在我可以从 Kafka 读取消息，但我想使用 spring 集成手动进行偏移管理，我可以使用 KafkaConsumer 使用查找方法来完成此操作，我可以返回队列。我想对 spring 集成做同样的事情是否有任何示例或文档可用

Answer 1

见 here和 here .

Apache Kafka 的新 Spring(目前基于 0.9 客户端)支持设置初始偏移量。见 the documentation .

使用接受 TopicPartitionInitialOffset 的监听器容器构造函数s。

spring-integration-kafka 2.0 被重写以构建在 spring-kafka 之上。

这两个项目都处于候选发布阶段，完整版本应该很快就会发布。