В одном из моих вариантов использования мне необходимо в потоковом режиме вводить данные из кассандры в свой поток данных.Я изучал архитектуру Cassandra и обнаружил, что Cassandra хранит свои журналы в папке журнала коммитов.Я попытался прочитать эти журналы, но безуспешно.
Кроме того, я исследовал разъем dasastax cassandra, но у него есть два недостатка:
- Поскольку он использует соединение JDBC, нагрузка на кластер cassandraможет стать слишком большим при увеличении количества таблиц.
- Поскольку это подход, основанный на запросах, нам придется запускать его каждые полчаса без потоковой передачи.
Любое решениеэто может помочь мне в получении данных в потоковом режиме приветствуется.