Моя цель - создать MQTT-сервис публикации / подписки , используя только Elasticsearch.
Сценарий, который я хотел бы реализовать, таков:
- Пользователь A создает сообщение (документ) внутри индекса Elasticsearch
- Пользователь B получает предупреждение и обновляется о новом сообщении в индексе.
Я использую простые Java-клиенты, поскольку в Android я не могу использовать поисковый клиент High Level Elastic.У меня есть все, что позволяет мне отправлять и читать документы из индекса ES, но я хотел бы найти лучший способ реализовать службу подписки для пользователя B, не заставляя его опрашивать обновления каждые несколько секунд.
Об этом я не знаю, с чего начать.Я не нашел ни одного триггера / службы веб-сокетов в ES.Пожалуйста, помогите с некоторыми идеями / документацией.