kafka操作步骤

        简介：下面是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