使用 Docker 创建单节点 Kafka
Apache Kafka 是一个分布式流处理平台，用于构建实时数据管道和流应用。Kafka 的优势在于其高吞吐量、可扩展性和容错能力。本文将介绍如何使用 Docker 在本地快速创建一个单节点 Kafka 实例。
环境准备
在开始之前，请确保已经安装了 Docker。如果尚未安装，可以按照 [Docker 官方文档]( 中的指引进行安装。
创建 Docker 网络
为了便于 Kafka 和 Zookeeper 之间的通信，我们需要创建一个 Docker 网络。可以使用以下命令：
docker network create kafka-net
启动 Zookeeper
Kafka 需要 Zookeeper 来管理集群和消息传递。可以通过 Docker 启动 Zookeeper 实例：
docker run -d \
--name zookeeper \
--network kafka-net \
-e ZOOKEEPER_CLIENT_PORT=2181 \
-e ZOOKEEPER_TICK_TIME=2000 \
wurstmeister/zookeeper:3.4.6
启动 Kafka
现在，我们可以启动 Kafka 服务。在 Kafka 的 Docker 容器中，指定 Zookeeper 的连接信息：
docker run -d \
--name kafka \
--network kafka-net \
-e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 \
-e KAFKA_LOG_DIRS=/var/lib/kafka/data \
-e KAFKA_NUM_PARTITIONS=1 \
-e KAFKA_REPLICATION_FACTOR=1 \
-p 9092:9092 \
wurstmeister/kafka:latest
在这里，KAFKA_ADVERTISED_LISTENERS 指定了 Kafka 节点将如何向外界报告其地址。
验证 Kafka 是否正常运行
完成以上步骤后，可以通过以下命令来检查 Kafka 服务的状态：
docker logs kafka
如果看到 Kafka 启动时的日志信息，那么表明 Kafka 已成功启动。
创建主题
Kafka 启动后，我们可以创建一个主题来测试消息的发布和订阅。执行以下命令以创建一个名为 test-topic 的主题：
docker exec -it kafka kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
发送和接收消息
发送消息
我们可以使用 Kafka 的命令行工具发送消息到 test-topic 主题：
docker exec -it kafka kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092
运行后，可以输入一些文本作为消息。输入完毕后，按 Ctrl+C 结束输入。
接收消息
接下来，我们可以通过以下命令来接收之前发送的消息：
docker exec -it kafka kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092
执行上述命令后，您将看到先前发出的消息。
旅程图
我们可以通过一个旅程图来展示从创建 Zookeeper 到 Kafka 实例，并最终能够发送接收消息的过程。
journey
title Kafka Setup Journey
section Create Docker Network
Create kafka-net: 5: Me
section Start Zookeeper
Run Zookeeper container: 5: Me
section Start Kafka
Run Kafka container: 5: Me
section Create Topic
Create test-topic: 4: Me
section Send Message
Send message using producer: 5: Me
section Receive Message
Receive message using consumer: 5: Me
流程图
以下是整个流程的流程图，包括每个步骤的顺序：
flowchart TD
A[创建 Docker 网络] --> B[启动 Zookeeper]
B --> C[启动 Kafka]
C --> D[创建主题]
D --> E[发送消息]
E --> F[接收消息]
结尾
通过以上步骤，我们在 Docker 中成功创建了一个单节点 Kafka 实例，并演示了如何创建主题、发送和接收消息。这种方法非常适合开发和测试环境，开发人员可以快速上手，灵活处理流数据。当您需要更复杂的生产环境时，可以考虑设置多节点的 Kafka 集群和更健壮的 Zookeeper 部署。希望这篇文章对您理解 Kafka 的使用有所帮助！
