Я изучаю Elastic Search, так что прости меня за этот стартовый вопрос.
Сценарий состоит в том, что у нас есть несколько производителей данных, которые отправляют данные в пожарный шланг AWS Kinesis, который настроен для их доставки в поиск AWS Elastic.Возможно, что одни и те же данные публикуются в пожарном шланге Kinesis несколькими производителями данных на основании различных изменений.
Поскольку Kinesis Firehose буферизует запрос и затем массово доставляет его в ES, существует вероятность того, что массовый запрос будет иметь несколько редакций одного и того же документа.
Как обеспечить, чтобы толькопоследний документ обработан?
Как примечание, все документы имеют поле метки времени, обозначающее время последнего изменения для него.