apache-kafka - 如何更改主题的起始偏移量？

Question

可以更改新主题的起始偏移量吗？我想创建一个新主题并从偏移量 10000 开始阅读.如何？

Answer 1

您可以在 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 的新实例，我不确定消费者是否会连接并创建消费者组。