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

Question

我有一个运行和接收消息的 kafka 队列。我已经使用ConsumeKafka api将 Nifi 与该主题（卡夫卡）连接起来。我想要一个处理器来读取这些消息并对其应用一些操作。

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

标签： pythonapache-kafkakafka-consumer-apiapache-nifi

Answer 1

在尝试了很多之后，这个答案给了我一个完美的见解。

我将在这里简要介绍一下我做了什么：

我认为这不需要解释。