我用的kafka版本是 kafka_2.12-2.3.0,zookeeper版本是 zookeeper-3.4.14
當用命令刪除topic時候，發現topic在zookkeeper中直接被刪除，kafka的儲存topic檔案被打上了刪除標記，用list命令也沒有看到該topic。過了大約1分鐘左右，再看topic在各個broker上的儲存檔案，竟然沒有topic了。在整個過程，並沒有配置 delete.topic.enable=true，topic直接被刪除了。
如果有生產者或者消費者在使用該topic，需要停掉生產者或者消費者才能進行刪除。
Kafka 如何從指定時間開始消費Topic
0.10.1.1版本的kafka增加了時間索引檔案，可以根據指定的時間戳計算出的offset來訪問topicpartition中的訊息。public class timestampoffsetconsumer consumer.assign topicpartitions 獲取每個partition...
kafka如何刪除group
我們在使用kafka消費資訊的過程中，不同group的consumer是可以消費相同的資訊的，group是在建立consumer時指定的，如果group不存在，會自動建立。其實簡單點說就是每個group都會在zk中註冊，區別就是註冊過還是沒註冊過。每個group內的consumer只能消費在grou...
刪除kafka 殘餘topics
delete topic folder from kafka broker machine.利用kafka bin topics delete刪除 一般重啟或者過段時間，kafka會自動剔出。這裡要說的是，kafka意外死亡，或者不停的更換topics，以至於不知道一些topics位於哪個broke...