无法本地连接容器化Kafka：Missing close-错误排查求助

核心错误原因 #

你遇到的解析异常是Python生产者脚本的配置格式错误：confluent-kafka库的Producer初始化时，bootstrap.servers参数要求是逗号分隔的字符串，而非列表类型。你传入了['localhost:19092']，导致librdkafka解析时出现语法错误，触发Missing close-']'的报错。

修改后的Python生产者脚本 #

from confluent_kafka.cimpl import Producer

def setup_kafka():
    # 修正：bootstrap.servers 使用字符串格式，而非列表
    producer = Producer({'bootstrap.servers': 'localhost:19092'})
    producer.produce("my-events", "my-test-message")
    producer.flush()

if __name__ == "__main__":
    setup_kafka()

额外检查项 #

1. Kafka容器配置验证：你的docker-compose.yml中KAFKA_ADVERTISED_LISTENERS配置正确，PLAINTEXT_HOST://localhost:19092允许本地主机连接容器内的Kafka服务，结合你已通过nc -zv localhost 19092验证端口连通性，这部分无需调整。
2. 脚本拼写修正：原脚本中的函数名setup_kakfa存在拼写错误（缺失字母f），虽然不影响运行，但建议修正为setup_kafka以保持代码规范性。

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