apache-kafka - Kafka主题的Nifi路由

Question

我正在尝试编写一个简单的工作流程，在其中读取 csv 文件，将其转换为 JSON，并基于 JSON 中存在的元素将特定 JSON 对象路由到 Kafka 主题。例如，我有 2 个 JSON 记录，其中一个具有“env”：“prod”，另一个具有“env”：“dev”。基于环境，我希望特定的 JSON 记录转到特定的 Kafka 主题。

我能够将 CSV 转换为 JSON。但是，我不确定如何从 JSON 记录中读取特定元素然后进行路由。任何帮助将不胜感激。如果可能，请简明扼要。

谢谢

标签： apache-kafkaroutingapache-nifi

Answer 1

您可以使用两个处理器EvaluateJSONPath和RouteOnAttriute来实现这一点。

这些链接有关于使用的详细文档。希望它会有所帮助。我在一个类似的用例中使用了相同的。