直接在kafka的bin目錄下執行命令： ### `./kafka-topics.sh --create --zookeeper 10.10.15.132:2181 --replication-factor 1 --partitions 1 --topic xdclass-topic` ### --zookeeper 10.10.15.132:2181指的是zk的地址和端口號要指定 ### --replication-factor 1 表示為topic創建一個副本 ### --partitions 1 表示這個topic(可以理解為庫)有一個partition(可以理解為表) ### --topic xdclass-topic 表示topic的名稱 ### 創建好topic之后我們可以在數據目錄當中查看到有目錄生成，因為我們在配置文件當中配置了數據存儲路徑： ###  ###  ### 如何查看有哪些topic呢？ ### `./kafka-topics.sh --list --zookeeper 10.10.15.132:2181` ### 查看的時候也要指定zk的ip和端口號 ###  ###