У меня есть две коллекции, пользователи и транзакции на mongodb, я отправил их в kafka и теперь мне нужно денормализовать их для ES?Я хочу иметь возможность анализировать транзакции по возрасту или что-то в этом роде.Как мне удается денормализовать мои темы, это происходит на уровне logstash?