Docker下安装Kafka的步骤

发布时间:2023-05-15 09:30:16

以下是在Docker下安装Kafka的步骤:

  1. 确保Docker和Docker已安装 Compose。
  2. 创建一个叫做“创建”的名字kafka文件夹,然后进入文件夹。
mkdir kafkacd kafka
  1. 在"kafka在文件夹中创建一个名字docker-compose.yml复制以下文件:
version: '3'services:  zookeeper:    image: wurstmeister/zookeeper    ports:      - "2181:2181"  kafka:    image: wurstmeister/kafka    ports:      - "9092:9092"    environment:      KAFKA_ADVERTISED_HOST_NAME: localhost      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

这个Docker Compose文件将启动Zookeper和Kafka服务,并曝光Zookeper端口2181和Kafka端口9092。

  1. 保存文件并退出编辑器。然后在终端中运行以下命令,启动Kafka集群:
docker-compose up -d

此命令将在后台启动Kafka和Zookeeper服务。

  1. 等待一段时间,直到所有的Kafka节点都开始。您可以使用以下命令查看正在运行的Docker容器:
docker ps

你应该看到两个容器在运行:一个是zookeper容器,另一个是kafka容器。

  1. 现在,您可以使用Kafka命令行工具或Kafka客户端应用程序连接到Kafka集群并开始使用它。例如,您可以使用以下命令创建一个名称“test"的主题:
docker-compose exec kafka \  kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --if-not-exists --zookeeper zookeeper:2181

这个命令将在Kafka集群上创建一个名字test“主题,只有一个分区和一个备份副本。

上一篇 树莓派 docker服务启动失败
下一篇 Java电影订票管理系统

文章素材均来源于网络,如有侵权,请联系管理员删除。

标签: Java教程Java基础Java编程技巧面试题Java面试题