【发布时间】:2022-01-06 05:07:57
【问题描述】:
我想从 Kafka 运行时传递参数(偏移量)中读取记录。
我使用的是@KafkaListener,但我无法设置用户请求的偏移运行时间。如果没有通过偏移量,它将消耗最新的记录。任何帮助表示赞赏。
【问题讨论】:
标签: apache-kafka kafka-consumer-api spring-kafka
我想从 Kafka 运行时传递参数(偏移量)中读取记录。
我使用的是@KafkaListener,但我无法设置用户请求的偏移运行时间。如果没有通过偏移量,它将消耗最新的记录。任何帮助表示赞赏。
【问题讨论】:
标签: apache-kafka kafka-consumer-api spring-kafka
最新的 2.8 版本有一个新功能,您可以使用 KafkaTemplate 在特定偏移处接收特定记录。
https://docs.spring.io/spring-kafka/docs/current/reference/html/#kafka-template-receive
如果您想从该偏移量接收所有记录,请使用容器提供的查找机制。
https://docs.spring.io/spring-kafka/docs/current/reference/html/#seek
【讨论】: