Ребят, всем привет! Перешел с kafka-python на confluent-kafka И не могу отправить

сообщение.

Вернее продьюсер создается, сообщение отправляется, ошибок нет, flush в конце делаю.
Но сообщения в топике нет.
Отправлял и авро, и джейсон, и простые тестовые словарики.

producer.produce(topic, message)
producer.poll(1)
producer.flush(1)
(пробовал и без указания времени)

Может быть ткнете, что не так, либо что еще можно попробовать?

Спасибо!

Ну посмотри что в caklback приходит, может там ощибка

Привет, сори, я пока не особо. Callback это это? https://developer.confluent.io/tutorials/kafka-producer-callback-application/confluent.html Это надстройка, которая позволяет возвращать что-то из метода produce?

что такое "надстройка" я не знаю. но это обычный callback судя по описанию.

Надстройка в самом обычном (не айти) понимании этого слова) Никогда callback’ом не пользовался, буду пробовать, спасибо!