Kafka創(chuàng)建topic的方法可以通過命令行工具kafka-topics.sh來實現(xiàn)。具體步驟如下:
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopic
其中,–zookeeper參數(shù)指定Zookeeper的地址,–replication-factor參數(shù)指定復制因子,–partitions參數(shù)指定分區(qū)數(shù)量,–topic參數(shù)指定要創(chuàng)建的topic名稱。