Мне нужно вставить большие объемные данные в Regularary эластичный поиск через Scala-код. При поиске в Google я обнаружил, что logstash используется для большой скорости вставки, но logstash не имеет библиотек Java или Api для вызова, поэтому я попытался подключиться к нему через http-клиент. Я не знаю, что это хороший подход для отправки больших данных по протоколу http или лучше использовать другие подходы, например, с использованием брокера, очередей, redis и т. Д.
Я знаю, что последние версии logstash (6.X, 7.x) позволяют использовать постоянную очередь, так что это может быть другим решением использовать очередь logstash, но снова через протокол http или tcp.
Также обратите внимание, что надежность является для меня первым приоритетом, поскольку данные не должны быть потеряны, и должен быть механизм для возврата ответа в коде, чтобы обрабатывать успех или неудачу.
Буду признателен за любые идеи.
Обновление
Кажется, использование http надежно и имеет механизм подтверждения, основанный на здесь , но если использовать этот подход, то какие библиотеки клиента http в scala являются более подходящими, так как мне нужно отправлять объемные данные в последовательности формата значения ключа и обработать ответ неблокирующим способом?