#apache-nifi
#apache-nifi
Вопрос:
У меня есть видеоданные, поступающие с устройства на процессор Apache-nifi, я хочу добавить временную метку в этот потоковый файл и сохранить в Kafka, используя процессор put Kafka. каков наилучший способ для этого?
Ответ №1:
Вы можете использовать UpdateAttribute процессор и использовать выражение Expression Language ${now():toNumber()} , чтобы выразить текущее время в миллисекундах и добавить это в качестве атрибута к потоковому файлу. Затем вы можете направить в PutKafka .
Комментарии:
1. В дополнение к тому, что сказал Энди, я просто хотел бы упомянуть, что, насколько я знаю, у Kafka нет атрибутов заголовка для каждого сообщения, поэтому единственный способ передать временную метку видео в kafka — это поместить временную метку в полезную нагрузку, которая затем делает это видео недействительным. больше.