Iam ищет решение, которое Как я могу синхронизировать Кассандру с упругим поиска т.е. любые данные записываются в Кассандре, она должна быть написана для упругого поиска такжеКак синхронизировать Кассандру и elasticsearch
Одним из способов было бы разработать который выполняется по расписанию или в цикле и считывает «новые» данные из Cassandra и отправляет их в Elasticsearch. Определение «новых» данных зависит от вашей схемы Cassandra и шаблонов вставки/обновления/удаления ваших приложений.
Это можно сделать как в режиме реального времени, так и в виде отдельного пакетного процесса.
Как и когда вы получаете данные в Кассандру на основе шаблона поиска/запроса, индексируйте данные в поиск Elastic.
Имейте слой обработки в реальном времени (например, Strom)/Распространенное сообщение сломалось, как Kafka, чтобы синхронизировать данные.
Или периодически запрашивайте данные из Cassandra и загружайте их в ES как отдельное пакетное задание.
Как узнать, что некоторые данные были добавлены или обновлены в cassandra? – manish