Docker容器网络 - Kafka生产者

下面是一个使用Docker容器网络和Kafka生产者的代码示例解决方法：

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

2. 创建一个名为docker-compose.yaml的文件，并添加以下内容：

version: '3'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - 2181:2181
  kafka:
    image: wurstmeister/kafka
    ports:
      - 9092:9092
    environment:
      - KAFKA_ADVERTISED_HOST_NAME=kafka
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
      - KAFKA_CREATE_TOPICS=test:1:1
    depends_on:
      - zookeeper
  producer:
    build:
      context: .
      dockerfile: Dockerfile
    depends_on:
      - kafka

3. 在与docker-compose.yaml相同的目录中，创建一个名为Dockerfile的文件，并添加以下内容：

FROM python:3.9
WORKDIR /app
COPY requirements.txt .
RUN pip install --no-cache-dir -r requirements.txt
COPY . .
CMD [ "python", "producer.py" ]

4. 在与docker-compose.yaml相同的目录中，创建一个名为producer.py的文件，并添加以下内容：

from kafka import KafkaProducer

# 创建Kafka生产者
producer = KafkaProducer(bootstrap_servers='kafka:9092')

# 发送消息到Kafka主题
producer.send('test', b'Hello, Kafka!')

# 关闭生产者连接
producer.close()

5. 在与docker-compose.yaml相同的目录中，创建一个名为requirements.txt的文件，并添加以下内容：

kafka-python

6. 打开终端，并导航到包含docker-compose.yaml文件的目录。

7. 运行以下命令启动Docker容器：

docker-compose up --build

8. Docker将启动Zookeeper、Kafka和生产者容器，并将它们连接到一个共享的容器网络中。

9. 生产者容器将发送消息到Kafka主题test。

10. 您可以通过运行以下命令来验证消息是否已成功发送到Kafka主题：

docker exec -it <kafka_container_id> kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

其中<kafka_container_id>是Kafka容器的ID。您可以通过运行docker ps命令来获取该ID。

这样，您就可以使用Docker容器网络和Kafka生产者发送消息到Kafka主题了。