Centos7 基于DOCKER 安装单机版Kafka

  • 时间:
  • 来源:互联网
  • 文章标签:

1 镜像安装

1.1 Docker镜像安装

1.1.1 Docker下查看是否有kafka的镜像

docker images |grep kafka

1.1.2 .拉取kafka镜像(如果没有kafka的镜像)

docker pull wurstmeister/kafka

1.2 Zookeeper镜像安装

1.2.1 .拉取zookeeper镜像
在Linux下查看是否有zookeeper的镜像

      docker images | grep zookeeper

1.2.2 如果没有 zookeeper 镜像,则拉去zookeeper镜像

docker pull wurstmeister/zookeeper

如果拉取报错:

Error response from daemon: Get https://registry-1.docker.io/v2/wurstmeister/zookeeper/manifests/latest: Get https://auth.docker.io/token?scope=repository%3Awurstmeister%2Fzookeeper%3Apull&service=registry.docker.io: net/http: request canceled (Client.Timeout exceeded while awaiting headers)

则需要提前去查找一下镜像:

docker search wurstmeister/zookeeper

再执行

docker pull wurstmeister/zookeeper

1.3 .查看是否成功

1 docker images
如下图: 在这里插入图片描述

2 启动zookeeper和kafka的镜像

2.1.启动zookeeper镜像

docker run -d --name zookeeper --publish 2181:2181 --volume /etc/localtime:/etc/localtime wurstmeister/zookeeper

2.2 启动kafka镜像

(切记 192.168.62.128 是我虚拟机ip,各位需要更换为自己的kafka镜像所在主机的ip)

docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=192.168.62.128  --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime wurstmeister/kafka

3 查看两个镜像是否启动成功

docker ps

在这里插入图片描述

4 测试kafka(生产/消费)消息

4.1 进入容器内部 查看kafka的 CONTAINER ID :

docker ps|grep kafka
        假设获取到的ID为:ba2540992d9e
       使用ID进入容器:
 docker exec -it ba2540992d9e /bin/bash

4.2 测试消息发送

在容器命令界面(具体进入/opt/kafkaxxxx 要ls一下 查看自己拉取的哪个版本的镜像产生的容器):

 cd /opt/kafka_2.12-2.1.0/

创建一个主题名为netmusic:

 bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic netmusic

运行一个生产者:

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

在另一个窗口打开容器命令窗口,运行一个消费者:172.17.0.3 是 kafka容器的ip。
可以通过进入kafka容器的命令窗口(docker exec -it ba2540992d9e /bin/bash),使用在docker中执行ifconfig或者退出用 docker inspect --format=’{{.NetworkSettings.IPAddress}}’ ID/NAMES 查询docker IP地址

  1 bin/kafka-console-consumer.sh --bootstrap-server 172.17.0.3:9092 --topic netmusic

在生产者的窗口生产消息,就可以在消费者窗口消费消息看到消息。

本文链接http://www.taodudu.cc/news/show-82947.html