docker安装kafka_docker 把kafka的配置文件过载出来

docker安装kafaka

1.安装最新docker

curl -fsSL https://get.docker.com/ | sh
1

1.1开机自启动

systemctl enable docker
1

1.2启动docker服务

systemctl start docker
1

1.3创建网络

docker network create app-tier --driver bridge
1

2.运行拉取zookeeper最新版

#因为卡夫卡依赖zookeeper注册中心
docker run -d --name zookeeper-server \
    --network app-tier \
    -e ALLOW_ANONYMOUS_LOGIN=yes \
    bitnami/zookeeper:latest
1
2
3
4
5

3.复制kafka配置文件 方便挂载

docker cp -a kafka-server:/opt/bitnami/kafka/config/ /home/kafka
1

4.运行并拉取kafka最新版

docker run -d --name kafka-server \
    --network app-tier \
	-v /home/kafka/config:/opt/bitnami/kafka/config\
    -p 9092:9092 \
    -e ALLOW_PLAINTEXT_LISTENER=yes \
    -e KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181 \
    -e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://服务器IP:9092 \
    bitnami/kafka:latest
1
2
3
4
5
6
7
8

​

4.1进入kafuka容器

docker exec -it kafka-serve /bin/sh
1

4.2创建topic

./kafka-topics.sh --create --bootstrap-server localhost:9092 \
--replication-factor 1 --partitions 1 --topic topic名称
1
2

4.3查看topic

./kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic  topic名称
1

4.4查看所有topic

./kafka-topics.sh --bootstrap-server localhost:9092 --list
1

4.5生产消息

./kafka-console-producer.sh --broker-list localhost:9092 --topic topic名称
1

4.6消费消息

./kafka-console-consumer.sh --bootstrap-server localhost:9092  --topic topic名称 --from-beginning
1

4.7删除topic

./kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic topic名称
1

4.8内外网配置

#内外网需要使用俩个端口,外网一个,内网一个
listeners=INTERNAL://:9092,EXTERNAL://:9098
advertised.listeners=INTERNAL://内网地址:9092,EXTERNAL://外网地址:外网端口
listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
inter.broker.listener.name=INTERNAL
1
2
3
4
5