gpt4 book ai didi

java - kafka自定义消费者读取传入记录

转载 作者:行者123 更新时间:2023-11-30 07:58:48 39 4
gpt4 key购买 nike

我已经使用新 API ( http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html ) 创建了一个 kafka 消费者

当前,消费者正在阅读主题中从最小偏移量开始的消息。我想覆盖它以从最新的偏移量读取。关于如何做到这一点的任何指示?

最佳答案

一旦您开始读取给定消费者组的消息,您将需要使用 seekToEnd() 方法显式强制消费者到达它所跟随的分区的末尾。对于尚未阅读任何消息的消费者组,您可以使用 auto.offset.reset=largest 属性告诉消费者在哪里阅读其第一条消息。

关于java - kafka自定义消费者读取传入记录,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40076757/

39 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com