此问题已在此处有答案：

Connect to Kafka running in Docker（6个回答）
关闭27天前。
我在使用本地机器上的Python代码与运行在容器中的Kafka Broker通信时遇到问题。我有一个docker compose文件来设置一个Kafka集群。这是yaml文件。

version: '3'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:7.0.0
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000

  kafka1:
    image: confluentinc/cp-kafka:7.0.0
    depends_on:
      - zookeeper
    ports:
      - "9092:9092"
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_LISTENERS: PLAINTEXT://:9092
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka1:9092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
      KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181"

这是成功的。当我在代理容器中时，我使用kafka-topics --create --topic my-topic --partitions 3 --replication-factor 1 --if-not-exists --bootstrap-server kafka1:9092命令创建一个主题，并使用kafka-console-producer --bootstrap-server kafka1:9092 --topic my-topic命令创建一个生产者。我将使用kafka-console-consumer --bootstrap-server kafka1:9092 --topic my-topic命令进一步使用消费者生成的消息。一切正常;现在，我想做同样的过程，但与Python从我的本地机器。我想从我的本地机器发送一条消息到我的docker容器中现有的Kafka主题;但是，我似乎无法从本地计算机与容器进行正确通信。下面是我使用的代码：

from confluent_kafka import Producer

# Producer configuration
producer_config = {
    'bootstrap.servers': 'kafka1:9092',
}

# Create a Kafka producer
producer = Producer(producer_config)

# Produce a message to a Kafka topic
producer.produce('my-topic', key='key', value='Hello, Kafka!')

# Wait for any outstanding messages to be delivered and delivery reports to be received
producer.flush()

这是我面临的错误：kafka 1：9092/bootstrap：无法解析'kafka 1：9092'：没有这样的主机是已知的。
有人能帮我吗？我如何以编程方式从本地机器向Docker容器中的现有主题发送消息？先谢谢你了。