Как выполнить CDC в снежинках и изменениях в Elasticsearch с использованием kafka и python? ⇐ Python

[Anonymous]

Я работаю над конвейером данных, где мне нужно реализовать сборы данных (CDC) в снежинок и транслировать эти изменения в Elasticsearch. Трубопровод должен использовать kafka для потоковой передачи и питона для оркестровки. < /P>
Вот чего я пытаюсь достичь: < /p>

Обнаружение изменений (вставки, обновления, удаляет) в определенных таблицах снежика. Тема. В частности, у меня есть эти вопросы: < /p>

Как лучше всего прочитать изменения из потока снежинки в питоне? Инструменты или библиотеки с открытым исходным кодом, которые могут помочь упростить этот процесс?

Подробнее здесь: https://stackoverflow.com/questions/795 ... g-kafka-an