получения сообщений. Может кто подскажет как на питоне подключиться?
не знаю, то ли это, что тебе нужно, но вот первая ссылка в гугле по запросу "kafka python" 🙃 https://pypi.org/project/kafka-python/
Спасибо. Я перепробовал множество библиотек, в том числе и эту. Но это немного для других задач. Ничего не подходит. Думал может кто сталкивался с подобной задачей.
асинхронно перетаскивать данные c удаленной Kafka в другую базу на SQL.
Звучит как самый стандартный консьюмер Кафки
так и звучит. Но по всем стандартным настройкам к yandexcloud kafka не могу подключиться. Техподдержка так же не смогла помочь. Общался с командой одной, они собрали собственный consumer для этого дела, так как тоже не смогли законнектится. Но понятно что не дадут списать)
Какая ошибка хоть?
kafka.errors.UnsupportedCodecError: UnsupportedCodecError: Libraries for snappy compression codec not found
А либы для snappy ставил?
А в настройках кластера какие типы сжатия стоят?
Обсуждают сегодня