Пикафка 2.3.1 Производитель Hang
Мы используем pykafka 2.3.1 и посмотреть, как продюсер зависает время от времени. Сообщение об ошибке:
Сообщение не доставлено!! UnknownTopicOrPartition("Произошел сбой при получении запроса на имя темы / от 0 до {ip: порт} с кодом ошибки 3".
Мы используем:
with topic_obj.get_producer(sync=False, linger_ms=10) as producer:
Кто-нибудь может помочь?