Docker 安装kafka 报错(连接kafka时)：
|
Error response from daemon: Container 38dc059cfa8ab610d3e288d969f9973b908dca7034a3588a4a8df1f39df2b06b is not running |
这 个问题只是zookeeper 和 kafka 版本的不兼容
1、开始安装:
|
//下载(无需指定版本,当前下载的最新版本是3.6.2)： docker pull zookeeper
//安装： docker run -d --restart=always --log-driver json-file --log-opt max-size=100m --log-opt max-file=2 --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime zookeeper |
|
下载： docker pull wurstmeister/kafka:2.12-2.1.0
安装： docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.2.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.2.128:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime -t wurstmeister/kafka:2.12-2.1.0 |
2、进行简单测试
①进入容器
|
docker exec -it kafka bash |
②进入 /opt/kafka_2.12-2.1.0/bin/ 目录下
|
cd /opt/kafka_2.12-2.1.0/bin |
③运行kafka生产者发送消息
|
./kafka-console-producer.sh --broker-list localhost:9092 --topic sun |
④发送消息
>输入任意字符串 后回车
⑤重新开一个ssh连接
⑥运行kafka消费者接收消息
|
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sun --from-beginning |
原文：https://www.cnblogs.com/tiankx/p/13940392.html