docker 配置 kafka

以下是使用Docker配置Kafka的步骤：

1. 首先，确保已经安装了Docker和Docker Compose。

2. 创建一个文件夹，用于存放Kafka的配置文件和数据。

3. 在该文件夹中创建一个名为`docker-compose.yml`的文件，并将以下内容复制到文件中：

version: '3'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:5.5.0
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000
    ports:
      - 2181:2181
    volumes:
      - ./data/zookeeper:/var/lib/zookeeper/data
      - ./data/zookeeper/logs:/var/lib/zookeeper/logs

  kafka:
    image: confluentinc/cp-kafka:5.5.0
    depends_on:
      - zookeeper
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
    ports:
      - 9092:9092
    volumes:
      - ./data/kafka:/var/lib/kafka/data

4. 在同一文件夹中创建一个名为`docker-compose up -d`的文件，并将以下内容复制到文件中：

#!/bin/bash
docker-compose up -d

5. 打开终端，导航到包含上述文件的文件夹，并运行以下命令启动Kafka容器：

chmod +x docker-compose up -d
./docker-compose up -d

6. 等待一段时间，直到Kafka容器成功启动。

7. 进入Kafka容器的bash终端，执行以下命令：

docker exec -it kafka bash

8. 在Kafka容器中，导航到Kafka的bin目录：

cd /opt/kafka_2.11-2.0.0/bin/

9. 创建一个名为`test`的topic，执行以下命令：

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

10. 创建一个生产者，向`test`topic发送消息，执行以下命令：

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

11. 现在，您可以在生产者终端中输入消息，并按Enter键发送消息。

请注意，上述步骤中的版本号和路径可能需要根据您使用的Kafka版本进行调整。