具有手动偏移管理弹簧集成的 Kafka

Question

我是 Kafka 的新手，我正在尝试很好地使用来自 Kafka 的消息，我可以借助来自 this 的基本 Kafka spring 集成示例来做到这一点

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

Answer 1

请参阅 here 和 here。

Apache Kafka 的新 Spring（当前基于 0.9 客户端）支持设置初始偏移量。见the documentation。

使用采用TopicPartitionInitialOffsets 的侦听器容器构造函数。

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

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