Kafka官方提供了兩個腳本來管理topic，包括topic的增刪改查。其中kafka-topics.sh負責topic的創建與刪除；kafka-configs.sh腳本負責topic的修改和查詢，但很多用戶都更加傾向於使用程序API的方式對topic進行操作 ...

1.pom 　　<dependency> 　　　　<groupId>org.apache.kafka</groupId> 　　　　<artifactId>kafka_2.10</artifactId> 　　　　< ...

　　前段時間在Kafka QQ群中有人問及此事——關於Java consumer如何動態修改topic訂閱的問題。仔細一想才發現這的確是個好問題，因為如果簡單地在另一個線程中直接持有consumer實例然后調用subscribe進行修改，consumer端必然會拋出異常 ...

前言 利用kafka命令刪除topic不成功。 原因&解決方式 1. 配置文件未將delete.topic.enable=true，導致刪除命令未及時生效； 解決方式： 第一種： 找到conf目錄下server.properties配置文件，修改 ...

一、Topic管理 1、創建topic 2、新增partition 注：topic一旦創建，partition只能增加，不能減少 3、刪除topic 4、查看topic列表 5、查看topic詳細信息 6、查看 ...

手動： 刪除kafka存儲目錄（server.properties文件log.dirs配置，默認為"/tmp/kafka-logs"）相關topic目錄 刪除zookeeper "/brokers/topics/"目錄下相關topic節點 命令+手動 ...

概述 　　在平時對kafka的運維工作中，我們經常會由於某些原因去刪除一個topic，比如這個topic是測試用的，生產環境中需要刪除。或者我想擴容topic的同時，這個topic中的數據我不想要了，這時候刪除topic，增加broker，再重新創建topic就會是比較簡單的方法。但是kafka ...

執行 windows 腳本 命令行程序，獲取 broker 元數據，計算副本分配方案，然后把 topic 的信息寫入 zk KafkaController 監聽 zk 節點的變化，並產生 TopicChange 事件 ...