confluent-kafka-python - 融合 kakfa 生产者 KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Local: Message timed out"}

Question

我是 Kafka 新手，使用 confluent kafka 并尝试使用带有 'sasl.mechanism': 'PLAIN','security.protocol': 'SASL_SSL' 的 python 生产者代码从 AWS EC2 实例向现有 kafka 主题写入消息。我试过了此链接中的生产者示例。出现以下错误。如果有任何可以指导我导致此问题的原因将有很大帮助。

 Failed to deliver message: KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Local: Message timed out"}