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