docker compose 搭建并运行kafka服务

以下是使用Docker Compose搭建并运行Kafka服务的简单步骤：

1. 首先，您需要创建一个docker-compose.yml文件，其中包含Kafka服务的配置。以下是一个简单的docker-compose.yml文件，用于启动单个Kafka节点：

version: '3'

services:
  zookeeper:
    image: 'bitnami/zookeeper:latest'
    ports:
      - '2181:2181'
    volumes:
      - 'zookeeper_data:/bitnami'

  kafka:
    image: 'bitnami/kafka:latest'
    ports:
      - '9092:9092'
    environment:
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
    volumes:
      - 'kafka_data:/bitnami'

volumes:
  zookeeper_data:
    driver: local
  kafka_data:
    driver: local

在上面的配置中，我们使用了Bitnami提供的Kafka和Zookeeper镜像，并将它们分别命名为zookeeper和kafka。我们还指定了Zookeeper的端口号为2181，Kafka的端口号为9092。

2. 然后，您需要在命令行中导航到包含docker-compose.yml文件的目录，并运行以下命令来启动Kafka服务：

docker-compose up -d

这将在后台启动Kafka服务。

3. 要检查Kafka服务是否正在运行，请使用以下命令：

docker-compose ps

这将显示正在运行的Kafka服务。

4. 最后，您可以使用Kafka的客户端工具来测试Kafka服务是否正在工作。例如，您可以使用以下命令向Kafka发送一条消息：

docker run --net=docker_kafkanet --rm confluentinc/cp-kafka:6.2.0 kafka-console-producer --broker-list kafka:9092 --topic test

然后，您可以使用以下命令从Kafka中读取消息：

docker run --net=docker_kafkanet --rm confluentinc/cp-kafka:6.2.0 kafka-console-consumer --bootstrap-server kafka:9092 --topic test --from-beginning

如果您看到了您发送的消息，则表示Kafka服务已经成功启动。