如何使用 Python 在 Nifi 中编写自定义处理器？

Question

我有一个 kafka 队列 运行 并且正在接收消息。 我使用 ConsumeKafka api 将 Nifi 与该主题（kafka）联系起来。 我想要一个处理器来读取这些消息并对它们应用一些操作。

根据这些需求，加入Nifi最好的方式是什么？

Answer 1

经过多次尝试，这个 给了我一个完美的见解。

我会在这里简单介绍一下我做了什么：

我认为这不需要解释。