要建立 Kafka 的 Topic,可以調用 kafka-topics.sh,帶入 –create 參數指定創建 topic、–zookeeper 參數指定 zookeeper 位置、–topic 參數指定要創建的 topic。

bin/kafka-topics.sh –create –zookeeper [ZooKeeper] –replication-factor [ReplicationFactor] –partitions [Partitions] –topic [Topic]

1.png