topic主題操作:
開啟kafka? bin/kafka-server-start.sh config/server.properties
或者 指令碼一鍵啟動 或者 進入到kafka的bin目錄 sh kafka-server-start.sh 開啟
每乙個kafka的命令都有寫入 --bootstrap-server node1.itcast.cn:9092 它是kafka的服務.後面跟著主機和網域名稱以及埠
1. kafka檢視幫助(要學會help)
bin/kafka-topics.sh --help
2. kafka列出所有topic
bin/kafka-topics.sh --bootstrap-server node1.itcast.cn:9092 --list
3. kafka建立 topic
bin/kafka-topics.sh --create --topic name --bootstrap-server 主機網域名稱:9092 --replication-factor 3 (3副本) --partitions 3 (分割槽為3)
bin/kafka-topics.sh --create --topic name --bootstrap-server node1.itcast.cn:9092 --replication-factor 3 (3副本) --partitions 3 (分割槽為3)
4.kafka刪除topic
bin/kafka-topics.sh --delete --topic name --bootstrap-server 主機網域名稱:9092
bin/kafka-topics.sh --delete --topic name --bootstrap-server node1.itcast.cn:9092
5.修改topic
bin/kafka-topics.sh --alter --topic name --bootstrap-server 主機網域名稱:9092 --partitons 3
bin/kafka-topics.sh --alter --topic name --bootstrap-server node1.itcast.cn:9092 --partitons 3
6.檢視topic
bin/kafka-topics.sh --describe --topic name --bootstrap-server 主機:9092
bin/kafka-topics.sh --describe --topic name --bootstrap-server node1.itcast.cn:9092
7.模擬生產者(產生資料) 消費者(消費資料)
kafka生產者:
bin/kafka-console-producer.sh --borker-list 主機網域名稱:9092 --topic name
bin/kafka-console-producer.sh --broker-list node1.itcast.cn:9092 --topic test
kafka消費者:
bin/kafka-console-consumer.sh --bootstrap-server 主機網域名稱:9092 --topic name
bin/kafka-console-consumer.sh --bootstrap-server node1.itcast.cn:9092 --topic test
Kafka主題 topic 的刪除
step1 如果需要被刪除topic 此時正在被程式 produce和consume，則這些生產和消費程式需要停止。因為如果有程式正在生產或者消費該topic，則該topic的offset資訊一致會在broker更新。呼叫kafka delete命令則無法刪除該topic。同時，需要設定 auto....
Kafka主題topic的增刪改查
windows 建立新主題的命令 kafka topics.bat create zookeeper localhost 2181 replication factor 1 partitions 1 topic hello kafka kafka中可以建立兩個相同名稱的主題，上面的命令執行兩次，將會...
kafka刪除topic的方法
0.8的官方文件提供了乙個刪除topic的命令 kafka topics.sh delete 但是在執行時會報錯找不到這個方法。kafka topics.sh最終是執行了kafka.admin.topiccommand這個類，在0.8的原始碼中這個類中沒有找到有delete topic相關的 在ka...