創建topic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytopic
bin/kafka-topics.sh? ?//bin目錄下的.sh??
--create --bootstrap-server? ? //固定寫法
localhost:9092? //ip端口
--replication-factor 1? 副本數量
--partitions 1? 分區數量
--topic //固定寫法
mytopic? //自己定義的topic名稱,根據自己的業務定義名稱,我的是jl_gj_topic1
查看上邊創建那些玩意
bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe