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