Как написать собственный процессор в Nifi, используя Python?

Question

У меня есть очередь kafka, работающая и получающая сообщения.Я связал Nifi с этой темой (о kafka), используя ConsumeKafka api.Я хочу иметь процессор, который будет читать эти сообщения и применять к ним некоторые операции.

Исходя из этих потребностей, что было бы наилучшим образом, находясь в Nifi?

Answer 1

После долгих попыток этот ответ дал мне идеальное понимание.

Я кратко опишу здесь, что я сделал:

Я не думаю, что это нуждается в объяснении.