使用docker-compose运行kafka及验证（无需zookpeer）

前言：要求安装docker-compose
   kafka镜像版本：apache/kafka:3.8.0
  大概存在镜像拉不下来的情况：

1、vim /etc/docker/daemon.json

1. {
2.   "data-root":"/data/docker",
3.   "registry-mirrors": [
4.     "https://docker.m.daocloud.io",
5.         "https://dockerproxy.com",
6.         "https://docker.mirrors.ustc.edu.cn",
7.         "https://docker.nju.edu.cn",
8.         "https://iju9kaj2.mirror.aliyuncs.com",
9.         "http://hub-mirror.c.163.com",
10.         "https://cr.console.aliyun.com",
11.         "https://hub.docker.com",
12.         "http://mirrors.ustc.edu.cn"
13.   ]
14. }

复制代码

2、编辑好后执行如下两条命令使修改的文件见效

1. systemctl daemon-reload
2. systemctl restart docker

复制代码

1、编辑docker-compose.yml

修改KAFKA_ADVERTISED_LISTENERS中的ip地址

1. version: '3'
2. services:
3.   kafka:
4.     image: apache/kafka:3.8.0
5.     container_name: kafka
6.     ports:
7.       - "9092:9092"
8.     environment:
9.       KAFKA_NODE_ID: 1
10.       KAFKA_PROCESS_ROLES: broker,controller
11.       KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093
12.       KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://xxx本机ipxxx:9092
13.       KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
14.       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
15.       KAFKA_CONTROLLER_QUORUM_VOTERS: 1@localhost:9093
16.       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
17.       KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
18.       KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
19.       KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
20.       KAFKA_NUM_PARTITIONS: 3

复制代码

2、启动

1. #启动
2. docker-compose up -d
3. #停止
4. docker-compose down
5. docker-compose stop

复制代码

3、验证

这边使用的是xshell，打开两个窗口A和B：
A窗口

• 进入kafka容器内
  

1. docker exec --workdir /opt/kafka/bin/ -it kafka sh

复制代码

• 创建topic
  

1. ./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test-topic

复制代码

• 进入生产者控制台，输入要发送的消息
  

   这边写入 ni hao

1. ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test-topic

复制代码

B窗口

• 进入kafka容器内
  

1. docker exec --workdir /opt/kafka/bin/ -it kafka sh

复制代码

• 打开消耗者控制台：自动吸收生产者的消息
  

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

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。