Создать конвейер захвата изменений для NoSQL

Требуется создать конвейер захвата измерений для NoSQL базы данных (Apache Cassandra). Для реализуется предлагается передавать логи СУБД в olap-систему (Hadoop, Apache Spark) для обработки. Передавать логи с использованием брокера сообщений