nifi PublishKafka：根据FlowFile属性的值或Content（Json文件的键）键创建partitionID

Question

我想创建一个属性值作为 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 处理器中找不到任何选项。 提前致谢

Answer 1

PublishKafka 处理器目前不允许您直接控制分区 ID。控制它的唯一方法是将“Paritioner Class”属性设置为“DefaultPartitioner”，然后指定消息键。这将散列消息键以确定分区。