apache-kafka - 如何从 Apache Nifi 中的 _consumeKafka_ 中提取一个键值对？

Question

我想在 Nifi 中使用consumeKafka来消费一个主题。由此，我想取出一个键值对并使用PutKafka将其放入另一个 Kafka 主题中。如何实现这一点并避免基于特定密钥的重复？

标签： apache-kafkakafka-consumer-apiapache-nifikafka-producer-api

Answer 1

如果以标准格式接收来自 Kafka 流的消息，那将是一件容易的事。如果接收消息在 JSON dormat 中，以下是执行此操作的步骤。

• 配置ConsumeKafka从主题接收
• 用于EvaluateJsonPath解析和读取特定键的值并将其分配给 NiFi FlowFile 属性
• 使用ReplaceText处理器形成您想要发送到另一个 Kafka 主题的您自己的消息（包含已解析的密钥）
• 将流与PutKafka

有关 EvaluateJsonPath 的更多详细信息，请参见此处和此处