【问题标题】:Runtime consume record from the offset in kafka spring boot来自kafka spring boot中偏移量的运行时消耗记录
【发布时间】:2022-01-06 05:07:57
【问题描述】:

我想从 Kafka 运行时传递参数(偏移量)中读取记录。 我使用的是@KafkaListener,但我无法设置用户请求的偏移运行时间。如果没有通过偏移量,它将消耗最新的记录。任何帮助表示赞赏。

【问题讨论】:

    标签: apache-kafka kafka-consumer-api spring-kafka


    【解决方案1】:

    最新的 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

    【讨论】:

    猜你喜欢
    • 2017-08-17
    • 2021-02-14
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-02-22
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多