可以更改新主题的起始偏移量吗?我想创建一个新主题并从偏移量 10000
开始阅读.如何?
最佳答案
您可以在 zookeeper shell 的帮助下执行此操作。 Kafka 使用 zookeeper 来跟踪消费者偏移量。
进入kafka bin目录,调用zookeeper shell。(我的kafka版本是0.8.0)
./zookeeper-shell.sh localhost:2181
现在使用 zookeeper get 命令
get /consumers/consumer_group_id/offsets/topic/0
它显示了类似的东西
2043
cZxid = 0x4d
ctime = Wed Mar 18 03:56:32 EDT 2015
...
这里 2043 是消耗的最大偏移量。使用 zookeeper set 命令将其设置为所需的值
set /consumers/consumer_group_id/offsets/topic/0 10000
该路径的框架如下/consumers/[consumer_group_id]/offsets/[topic]/[partition_id]。
您必须使用适当的消费者组、主题和分区 ID 来替换。
*此外,由于您提到它是 kafka 的新实例,我不确定消费者是否会连接并创建消费者组。
关于apache-kafka - 如何更改主题的起始偏移量?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29791268/