指令碼手工建立

./bin/kafka-topics.sh –zookeeper 192.168.2.225:2183/config/mobile/mq –create –topic test.example –replication-factor 2 –partitions 24
–topic指定topic name
–partitions指定分割槽數，這個引數需要根據broker數和資料量決定，正常情況下，每個broker上兩個partition最好；
–replication-factor指定partition的replicas數，建議設定為2；

程式自動建立：

開啟自動建立配置：auto.create.topics.enable=true
使用程式直接往kafka中相應的topic傳送資料，如果topic不存在就會按預設配置進行建立。