Прием друида Кафки с чтением-записью

Question

Я учу друида сейчас.Я читал, что прием через Kafka Indexing Service гарантирует семантику "точно один раз".

Однако у меня есть проблема с определением модели согласованности Druid.Обычно потоки асинхронны, но я хочу, чтобы в приложении была семантика чтения-записи-записи.

Есть ли возможность проверить состояние приема Друида?Например, я отправляю событие A и хочу проверить, было ли оно уже сохранено в Druid.Если да, запрос к друиду должен возвращать результат с этим значением.

Может быть, есть какая-то другая возможность сделать прием в реальном времени с семантикой "точно один раз" и с чтением-записью?

Answer 1

Друид имеет отдельный процесс приема пищи и чтения данных.чтение-ваши-записи напрямую невозможно, однако вы можете добиться успеха для записи, а затем сделать отдельный запрос на чтение вашей записи.

проверить сервер успокоения, который предоставляет http на основе httpшлюз для записи в режиме реального времени, и он пытается обрабатывать ровно один раз при приеме внутрь.

Хотя лучший подход для обеспечения точно однократного приема - это повторное индексирование путем пакетного приема через регулярные промежутки времени, в зависимости от вашего варианта использования.