想要运行kafka。发现windows系统运行kafka经常报问题怎么办？linux系统环境太复杂怎么办？

本文针对kafka服务器的启动，介绍如何利用docker在容器内运行kakfa的server。

1. 环境说明

docker提供了相对独立简洁的运行环境，能够让kafka的服务端良好独立地运行，遇到问题也方便进行排查。

经常使用的kafka镜像有wurminster/kafka, bitnami/kafka这两种，都可以使用。本文使用bitnami/kafka，并结合zookeeper使用（kafka的运行基础）。

docker: 24.0.6

镜像bitnami/kafka: 2.8.1

镜像bitnami/zookeeper: latest

镜像dushixiang/kafka-map:latest(kafka的管理界面，可同时启动使用)

不同版本基本不会对运行产生影响。

2. 方法介绍

为了让kafka有健全的运行体系，并且方便我们一键式地开启或关闭kafka的server，利用docker compose工具来建立一个由多容器构成的整体服务。

2.1. 文件准备

创建一个kafka文件夹，文件夹中创建2个文本文件，重命名为.env和compose.yaml

2.1.1. .env文件

.env文件的作用为设置环境变量，方便我们修改相关的参数，如端口、版本等。

ZOOKEEPER_IMAGE_VERSION='latest' KAFKA_IMAGE_VERSION='2.8.1' KAFKA_MAP_IMAGE_VERSION='latest' ZOOKEEPER_PORT=2181 KAFKA_PORT=9092 KAFKA_MAP_PORT=9001 

2.1.2. compose.yaml文件

docker compose进行启动服务的执行文件，根据文件内容运行对应镜像。

将生成zookeeper，kafka，kafka-map三个容器。

services:   zookeeper:     image: bitnami/zookeeper:${ZOOKEEPER_IMAGE_VERSION}     container_name: zookeeper     ports:       - ${ZOOKEEPER_PORT}:2181     environment:       - ALLOW_ANONYMOUS_LOGIN=yes     networks:       - app-tier    kafka:     image: bitnami/kafka:${KAFKA_IMAGE_VERSION}     container_name: kafka     ports:       - ${KAFKA_PORT}:9092     environment:       - KAFKA_CFG_NODE_ID=1       - ALLOW_PLAINTEXT_LISTENER=yes       - KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper:2181       # - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092  不用advertised会导致client无法连接       - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:${KAFKA_PORT}     networks:       - app-tier    kafka-map:     image: dushixiang/kafka-map:${KAFKA_MAP_IMAGE_VERSION}     container_name: kafka-map     restart: always     ports:       - ${KAFKA_MAP_PORT}:8080     environment:       - DEFAULT_USERNAME=admin       - DEFAULT_PASSWORD=admin     volumes:       - /opt/kafka-map/data/:/usr/local/kafka-map/data     networks:       - app-tier  networks:   app-tier: 

2.2. 运行命令

打开cmd并cd到kafka文件夹的路径。

输入下方命令

docker compose up -d

 成功运行将显示

此时即说明kafka的server已运行成功。

3. 后续操作

3.1. 运行client客户端（consumer和producer)

我的本机是windows，可以通过在windows安装kafka来生成producer和consumer。

也可以利用python代码，来生成producer和consumer。

client客户端的运行将依赖于docker生成的kafka server端，如果server停止运行，client会出问题。

3.1.1. 通过windows安装的kafka运行

首先在cmd中cd到kafka的执行路径。

cd "G:\kafka_2.13-2.8.1\bin\windows"

利用以下代码产生consumer或producer，注意一个窗口只能开一个，两个都开要两个窗口。

# 启动consumer kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning # 启动producer kafka-console-producer.bat --broker-list localhost:9092 --topic test

3.1.2. python代码生成

首先python环境中需安装kafka-python

producer: 每秒钟由producer发送时间

from kafka import KafkaProducer import time   if __name__ == "__main__":     producer = KafkaProducer(bootstrap_servers='localhost:9092',                              api_version=(2, 8, 1))     print('Producer is ready to send messages')     while True:         time.sleep(1)         msg = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())         print(msg)         msg = msg.encode('utf-8')         producer.send(topic='python', value=msg) 

consumer

from kafka import KafkaConsumer import os   if __name__ == "__main__":     consumer = KafkaConsumer('python',                             bootstrap_servers=['localhost:9092'],                             group_id = str(os.getpid()),                             api_version=(2, 8, 1),                             auto_commit_interval_ms=5000,                             )      for msg in consumer:         value = msg.value.decode('utf-8')         recv = "%s:%d:%d: key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, value)         print(recv) 

3.2. kafka相关信息查看

这里以通过zookeeper查看当前已有的broker（即kafka的server端）为例。

在cmd中运行

docker exec -it zookeeper bin/bash zkCli.sh

进入该容器后，运行

# 查看当前已有的broker的id ls /brokers/ids # 输出: [1, 2, 3] # 获取该broker的信息 get /brokers/ids/<某id>

参考资料

Docker安装Kafka教程（超详细）

kafka各种环境安装(window,linux,docker,k8s),包含KRaft模式

解决Docker容器连接 Kafka 连接失败问题