如何使用Python在Nifi中编写定制的处理器？

Question

我有一个kafka队列正在运行并接收消息。 我已经使用consumerkafkaapi将Nifi与该主题（关于kafka）连接起来。 我想有一个处理器，它可以读取这些消息并对它们应用一些操作。在

基于这些需求，加入Nifi的最佳方式是什么？在

Answer 1

经过多次尝试，这个answer给了我一个完美的洞察力。在

我将在这里简要介绍我所做的：

我不认为这需要解释。在