PublishKafka:基于FlowFile属性值或内容(Json文件的密钥)键创建FlowFile

Question

我想为卡夫卡主题创建一个属性值作为partitionID。例如，我的flow文件属性列表有：account_number作为属性之一。和account_number can have different values eg, 111,222,121 etc。然后，111, 222, 121 etc将成为我的卡夫卡主题的PartitionID，因为我希望得到按时间戳排序的消息。我在nifi的PublishKafka__10处理器中找不到任何选择。提前感谢

Answer 1

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