简介：下面是kafka集群的一些操作步骤，由于步骤较多在这里写下来，一来整理一下记忆、二来以防自己遗忘后没有熟悉的操作说明。以下内容都是建立在kafka集群搭建好后的基础上的。
一、开启kafka集群
开启zookeeper集群(千万不要开启kafka自带的zookeeper集群)
zkServer.sh start &
有多少台虚拟要就要开启多少次，建议在后面加& 让集群在后台运行
启动成功后输入jps看一下进程
三台虚拟机上都显示出QuorumPeerMain然表示zookeeper启动成功
然后是启动KAFKA服务（每台虚拟机都需要启动一次）
bin/kafka-server-start.sh config/server.properties &
开启成功后用jps看一下进程
每台虚拟机上都有kafka这个进程，表示kafka启动成功了.
下面要做一个通信接收功能
首先创建 topic(ip是本机ip)
bin/kafka-topics.sh --create --zookeeper 192.168.200.11:2181 --replication-factor 2 --partitions 1 --topic elm
创建一个producer，发布者（ip是主机ip）
bin/kafka-console-producer.sh --broker-list 192.168.200.11:9092 --topic elm
创建一个consumer, 订阅者(ip是本机ip)
bin/kafka-console-consumer.sh --bootstrap-server 192.168.200.13:9092 --topic elm --from-beginning
然后发送都发布消息、订阅者接收到消息，则证明kafka集群搭建成功
查看topic列表
bin/kafka-topics.sh --list --zookeeper localhost:2181
