У меня проблема, из Kafka будет приходить несколько событий для одного и того же идентификатора сообщения. Я хочу использовать logsta sh для pu sh поиска событий в elasti c во вложенных документах. Как мы можем поместить sh данные в elasticsearch через logsta sh как вложенные документы.
Может ли кто-нибудь помочь в этом отношении?
Пример:
- Msg_id - событие m1 - отметка времени msg_requested - 1234
Msg_id - событие m1 - карта времени msg_received - 1235
Msg_id - событие m1 - msg_delivered timestmap - 1236
Эти события могут иметь другую временную метку, первое событие для msg_id создаст родительский do c. Я хочу, чтобы данные внутри поиска elasti c выглядели так:
"ts": "1234", "id": "m1", "sets": [{"ts": "1234" , "et": "msg_requested"}, {"ts": "1235", "et": "msg_received"}, {"ts": "1236", "et": "msg_delivered"}]}