kafka如果修改偏移量

Ｅiaranˉ 发表于: 2018-01-12   最后更新时间: 2018-01-12 08:49:27   6,209 游览

大神，您好，kafka偏移量保存zookeeper和kafka，zookeeper中可通过命名修改偏移量，kafka中如何修改偏移量？consumer.seek(new TopicPartition(topic, partition), offset);好像并没有起作用

kafka
发表于 2018-01-12
Ｅiaranˉ
添加评论

是这个命令的。

回复
回答于 6年前
半兽人
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。