1 ZooKeeper框架安装
步骤1.1 - 下载ZooKeeper
要在您的机器上安装ZooKeeper框架，请访问以下链接并下载最新版本的ZooKeeper。
http://zookeeper.apache.org/releases.html
截至目前，ZooKeeper的最新版本为3.4.6（ZooKeeper-3.4.6.tar.gz）。
步骤1.2 - 提取tar文件
使用以下命令提取tar文件
$ cd opt/
$ tar -zxf zookeeper-3.4.6.tar.gz
$ cd zookeeper-3.4.6
$ mkdir data
步骤1.3 - 创建配置文件
使用命令vi“conf / zoo.cfg” 打开名为conf / zoo.cfg的配置文件，并将所有以下参数设置为起始点。
$ vi conf/zoo.cfg
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
syncLimit=2
一旦配置文件成功保存并再次返回终端，就可以启动zookeeper服务器。
步骤1.4 - 启动ZooKeeper服务器
$ bin/zkServer.sh start
执行此命令后，您会得到如下所示的响应：
$ JMX enabled by default
$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg
$ Starting zookeeper ... STARTED
步骤1.5 - 停止Zookeeper服务器
连接服务器并执行所有操作后，可以使用以下命令停止zookeeper服务器 -
$ bin/zkServer.sh stop
现在，您已经在您的机器上成功安装了Java和ZooKeeper。让我们看看安装Apache Kafka的步骤。
2 - Apache Kafka安装
让我们继续以下步骤在您的机器上安装Kafka。
步骤2.1 - 下载kafka
要在您的机器上安装Kafka，请点击下面的链接 -
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz
现在最新的版本，即 - kafka_2.11_0.9.0.0.tgz将被下载到你的机器上。
步骤2.2 - 提取tar文件
使用以下命令提取tar文件 -
$ cd opt/
$ tar -zxf kafka_2.11.0.9.0.0 tar.gz
$ cd kafka_2.11.0.9.0.0
现在您已经在您的机器上下载了最新版本的Kafka。
步骤2.3 - 启动服务器
您可以通过以下命令启动服务器 -
$ bin/kafka-server-start.sh config/server.properties
服务器启动后，您将在屏幕上看到以下响应：
$ bin/kafka-server-start.sh config/server.properties
[2016-01-02 15:37:30,410] INFO KafkaConfig values:
request.timeout.ms = 30000
log.roll.hours = 168
inter.broker.protocol.version = 0.9.0.X
log.preallocate = false
security.inter.broker.protocol = PLAINTEXT
步骤2.4 - 停止服务器
执行所有操作后，可以使用以下命令停止服务器 -
$ bin/kafka-server-stop.sh config/server.properties
3 kafka操作
3.1 创建topic
[root@192-168-123-169 bin]# ./kafka-topics.sh --create --topic test --replication-factor 1 --partitions 1 --zookeeper localhost:2181
Created topic "test".
3.2 在topic中发送消息
[root@192-168-123-169 bin]# ./kafka-console-producer.sh --topic test --broker-list 192.168.123.169:9092
abc
ddd
aaa
ddd
whoami
3.3 消费者接受消息
[root@192-168-123-169 kafka_2.11-0.9.0.0]# bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --from-beginning --topic test
abc
ddd
aaa
ddd
whoami
