直接在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和端口号 ###  ###