kafka安装（清流手册）

Kafka安装：

下载安装包：wget http://mirrors.shu.edu.cn/apache/kafka/2.1.0/kafka_2.11-2.1.0.tgz

* * *

## 1使用kafka内置zk启动以及测试

功能验证：

* **启动kafka内嵌的zk（前台启动）**：bin/zookeeper-server-start.sh config/zookeeper.properties

    * lsof -i:2181 （查看2181端口是否被监听）

* **启动kafka服务** : bin/kafka-server-start.sh config/server.properties

    * lsof -i:9092（查看9092端口是否被监听）

* **创建 topic** : bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test1 --partitions 3 --replication-factor 1

* bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test1

* 查看topic列表： bin/kafka-topics.sh --list --zookeeper localhost:2181

* bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

* bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1（已经过时）

* bin/kafka-console-consumer.sh --bootstrap-server localhost:9092  --topic test1（亲测可用，version：kafka_2.11-2.1.0）

* * *

## 2使用外部的zk配合启动kafka

* 准备工作

    * 检查zookeeper和kafka服务已经被kill

        * ps -ef|grep -i kafka

        * ps -ef|grep -i zookeeper

        * rm -rf /tmp/kafka-logs  ,rm -rf /tmp/zookeeper （删除文件，以免干扰）

* 启动外置zk

    *  bin/zkServer.sh start conf/zoo.cfg

    *  bin/kafka-server-start.sh config/server.properties

    *  bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test1 --partitions 3 --replication-factor 1

    *  bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1 (窗口1)

    *  bin/kafka-console-consumer.sh --bootstrap-server localhost:9092  --topic test1 （窗口2）

* * *

使用zookeeper dockerfile 构建 docker image：

docker build -t skywp/zookeeper:3.4.6 -f zookeeper.Dockerfile . (注意docker build最后有一个点)