Apache Kafka（Bitnami镜像）Python生产者消息无法写入主题求助

以下是针对你遇到的Python生产者消息无法被控制台消费者读取问题的排查步骤和解决方法：

1. 显式配置Kafka生产者参数 #

原代码未明确指定连接地址和消息确认策略，虽然kafka-python默认连接localhost:9092，但显式配置能避免潜在的环境歧义，同时确保消息被Broker正确接收：

from kafka import KafkaProducer
from kafka.errors import KafkaError

# 配置生产者，指定连接地址、序列化规则及消息确认策略
producer = KafkaProducer(
    bootstrap_servers=['localhost:9092'],
    value_serializer=lambda x: x.encode('utf-8'),  # 自动处理字符串转字节
    acks='all',  # 要求所有同步副本确认消息
    retries=3,   # 发送失败时重试3次
    linger_ms=10
)

TOPIC = 'testtopic'
msg = "Test message"

# 发送消息并等待结果，捕获可能的异常
try:
    # 等待10秒获取发送结果
    record_metadata = producer.send(TOPIC, msg).get(timeout=10)
    print(f"消息已确认：主题={record_metadata.topic}, 分区={record_metadata.partition}, 偏移量={record_metadata.offset}")
except KafkaError as e:
    print(f"发送失败：{str(e)}")

producer.flush()
producer.close()

2. 修正控制台消费者命令 #

确保控制台消费者使用正确的命令，添加--from-beginning参数可以读取主题中所有历史消息（包括你之前发送的）：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testtopic --from-beginning

3. 检查Kafka主题状态 #

用以下命令查看主题的分区和副本状态，确认主题处于正常可用状态：

kafka-topics.sh --describe --topic testtopic --bootstrap-server localhost:9092

输出中需确保Leader和Replicas列无异常（比如Leader: -1表示分区不可用）。

4. 验证Bitnami Kafka容器配置 #

• 确认容器端口映射正确：启动容器时已将主机9092端口映射到容器9092端口（比如启动命令包含-p 9092:9092）
• 查看容器内的server.properties配置，确保listeners和advertised.listeners设置为PLAINTEXT://localhost:9092，避免外部客户端无法正确连接：

docker exec <你的Kafka容器名称> cat /opt/bitnami/kafka/config/server.properties | grep -E "listeners|advertised.listeners"

内容的提问来源于stack exchange，提问作者DanM84