將卡夫卡主題的潛在客戶設置爲-1

我正在使用Spark流在集羣上使用kfka主題。我會重新安排我的流媒體應用程序，並希望再次閱讀主題mnessages。將卡夫卡主題的潛在客戶設置爲-1

有沒有辦法重置羣集上的kafka主題線索？

當我描述的主題我得到波紋管描述：

Topic:mahditest PartitionCount:3  ReplicationFactor:2  Configs: 
     Topic: mahditest  Partition: 0 Leader: 1020 Replicas: 1020,1019  Isr: 1020,1019

，但我需要反感導致-1爲每一個主題，所以我可以重新讀取消息。

2017-08-15 Luckylukee

取決於你正在存儲的偏移量，但如果你是在卡夫卡使用新的消費API存儲它們，然後在卡夫卡0.11，你可以重置任何卡夫卡消費者的偏移量（存儲__consumer_offsets主題）如果您運行

$ kafka-consumer-groups.sh --bootstrap-服務器localhost：9092 --topic mahditest --group yourconsumer --reset-偏移--to-最早--execute

你應該關閉所有消費者在運行重置偏移命令之前的組中

此命令的0.11版本還應該可以重置0.10.2羣集上的偏移量

2017-08-15 02:49:01

回答