Docker安装Kafka

简单安装为了集成 SpringBoot，真实使用，增加增加更多配置，比如将log映射出来

1.下载镜像

docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka

2. 安装 zookeeper

docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper

3、启动kafka

• （如果服务器在云上，换成外网ip（192.168.1.1））

docker run  -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=10.17.0.19:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.17.0.19:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka

4、进入容器

docker exec -it kafka /bin/bash
cd /opt/kafka_{your_kafka_version}/bin

5、进行测试

• 打开生产者和消费者，进行测试

#创建主题
kafka-topics.sh --create --zookeeper zookeeper地址:2181 --replication-factor 1 --partitions 1 --topic kafkatest  


#窗口1 生产 添加消息
kafka-console-producer.sh --broker-list localhost:9092 --topic kafkatest
#或者直接以下：
kafka-console-producer.sh --broker-list localhost:9092 --topic vipsoft_kafka


#窗口2 消费 消费消息
docker exec -it kafka /bin/bash

kafka-console-consumer.sh --zookeeper zookeeper地址:2181 --topic kafkatest --from-beginning
#或者直接以下：
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic vipsoft_kafka --from-beginning