nifi PublishKafka：根据 FlowFile 属性的值或内容（Json 文件的键）键创建 partitionID
nifi PublishKafka: Creating partitionID based on FlowFile attribute's value or Content (Json file's key) key
我想创建一个属性值作为 kafka 主题的 partitionID。例如，我的流文件属性列表具有：account_number 作为属性之一。和 account_number can have different values eg, 111,222,121 etc。然后 111, 222, 121 etc 将成为我的 kafka 主题的 PartitionID，因为我想获取按时间戳排序的消息。
我在 nifi 的 PublishKafka_0_10 处理器中找不到任何选项。
提前致谢
PublishKafka 处理器目前不允许您直接控制分区 ID。控制它的唯一方法是将 "Paritioner Class" 属性 设置为 "DefaultPartitioner" 然后指定消息密钥。这将散列消息密钥以确定分区。
我想创建一个属性值作为 kafka 主题的 partitionID。例如，我的流文件属性列表具有：account_number 作为属性之一。和 account_number can have different values eg, 111,222,121 etc。然后 111, 222, 121 etc 将成为我的 kafka 主题的 PartitionID，因为我想获取按时间戳排序的消息。
我在 nifi 的 PublishKafka_0_10 处理器中找不到任何选项。
提前致谢
PublishKafka 处理器目前不允许您直接控制分区 ID。控制它的唯一方法是将 "Paritioner Class" 属性 设置为 "DefaultPartitioner" 然后指定消息密钥。这将散列消息密钥以确定分区。