nifi PublishKafka：基于 FlowFile 属性的值或 Content (Json 文件的键) 键创建分区 ID

Question

我想创建一个属性值作为 kafka 主题的分区 ID。例如，我的流文件属性列表将：account_number作为属性之一。和account_number can have different values eg, 111,222,121 etc.然后111, 222, 121 etc将是我的 kafka 主题的分区 ID，因为我想获取按时间戳排序的消息。 我在 nifi 的处理器中找不到任何选项PublishKafka_0_10。 提前致谢

Answer 1

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