Слитный производитель Kafka KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Локальный: время ожидания сообщения истекло"} ⇐ Python

[Anonymous]

Я новичок в Kafka, использую confluent kafka и пытаюсь писать сообщения в существующую тему kafka из экземпляра AWS EC2, используя код производителя Python с 'sasl.mechanism': 'PLAIN','security.protocol': 'SASL_SSL'. Я попробовал пример производителя по этой ссылке. Возникает следующая ошибка. Если кто-нибудь может подсказать мне, что приведет к этой проблеме, это будет очень полезно.
Failed to deliver message: KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Local: Message timed out"}


Подробнее здесь: https://stackoverflow.com/questions/667 ... -local-mes