Docker 安装kafka 并创建topic 进行消息通信-Toy模板网

这篇具有很好参考价值的文章主要介绍了Docker 安装kafka 并创建topic 进行消息通信。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

docker kafka 创建topic,docker,kafka,docker,kafka,容器

Apache Kafka是一个分布式流处理平台，用于构建高性能、可扩展的实时数据流应用程序。本文将介绍如何使用Docker容器化技术来安装和配置Apache Kafka。

docker kafka 创建topic,docker,kafka,docker,kafka,容器

一、使用镜像安装

1、kafka安装必须先安装Zookpper

2、下载镜像

docker pull wurstmeister/kafka

3、查看下载好的镜像

docker images

4、启动Kafka

docker run -d --name kafka --publish 9092:9092 \ --link zookeeper \ --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \ --env KAFKA_ADVERTISED_HOST_NAME=127.0.0.1 \ --env KAFKA_ADVERTISED_PORT=9092 \ wurstmeister/kafka

5、查看是否创建好Kafka容器

docker ps

6、进入到Kafka容器内

sudo docker exec -it kafka /bin/bash

7、创建topic

cd opt/kafka_2.13-2.6.0/bin

docker kafka 创建topic,docker,kafka,docker,kafka,容器

创建topic

./kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 8 --topic test Created topic test.

8、创建成功之后发送消息

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

docker kafka 创建topic,docker,kafka,docker,kafka,容器

9、重新打开一个终端，创建消费者

sudo docker exec -it kafka /bin/bash cd opt/kafka_2.13-2.6.0/bin/ ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning #若不想从头消费就使用 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

docker kafka 创建topic,docker,kafka,docker,kafka,容器

这样就能接受到生产着生产的数据了

10、查看、删除Kafka中的所有的topic

#查看 ./kafka-topics.sh --list --bootstrap-server ZK地址:端口
./kafka-topics.sh --list --bootstrap-server localhost:9092

#删除 ./kafka-topics.sh --delete --bootstrap-server ZK地址:端口 --topic topic名
./kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic local_point

二、使用Docker Compose安装

1. 安装Docker和Docker Compose

首先，确保你的系统已经安装了Docker和Docker Compose。你可以根据操作系统的不同，按照官方文档的指引进行安装。

2. 创建Docker Compose文件

在你的项目目录下创建一个名为`docker-compose.yml`的文件，并添加以下内容：

services:
zookeeper:
image: confluentinc/cp-zookeeper:6.2.0 ports:
- "2181:2181"
environment:
- ZOOKEEPER_CLIENT_PORT=2181 - ZOOKEEPER_TICK_TIME=2000 kafka:
image: confluentinc/cp-kafka:6.2.0 ports:
- "9092:9092"
environment:
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092 - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 depends_on:
- zookeeper```

3. 启动Kafka集群

打开终端，进入到包含`docker-compose.yml`文件的目录，并执行以下命令启动Kafka集群，如下命令Docker将会下载所需的镜像，并启动一个包含Zookeeper和Kafka的容器集群。

bashdocker-compose up -d

4. 验证Kafka集群是否正常运行

执行以下命令，查看Kafka集群的运行状态：如果所有容器都处于运行状态，则表示Kafka集群已成功启动。

bashdocker-compose ps

5. 使用Kafka

现在可以使用Kafka进行消息的发布和订阅。可以使用Kafka的命令行工具或者编程语言的Kafka客户端库来与Kafka集群进行交互。

6. 停止和清理

如果想停止Kafka集群并清理相关的容器和资源，可以执行以下命令，Docker将会停止并删除相关的容器和网络。

bashdocker-compose down

结论：
通过使用Docker容器化技术，我们可以方便地安装和配置Apache Kafka，快速搭建一个可用的Kafka集群。这为我们开发和测试实时数据流应用程序提供了便利，同时也提供了良好的可扩展性和灵活性。文章来源地址https://www.toymoban.com/news/detail-840306.html

到了这里，关于Docker 安装kafka 并创建topic 进行消息通信的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！