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最后有一个点)