我想创建一个属性值作为Kafka主题的分区ID。例如，我的流文件属性列表有： account_number 作为属性之一。以及 account_number can have different values eg, 111,222,121 etc . 那么 111, 222, 121 etc 将分区为我的Kafka主题，因为我想得到按时间戳排序的消息。我在nifi的kafka\u0\u10处理器上找不到任何选项。提前谢谢
我想创建一个属性值作为Kafka主题的分区ID。例如，我的流文件属性列表有： account_number 作为属性之一。以及 account_number can have different values eg, 111,222,121 etc . 那么 111, 222, 121 etc 将分区为我的Kafka主题，因为我想得到按时间戳排序的消息。我在nifi的kafka\u0\u10处理器上找不到任何选项。提前谢谢
1条答案
按热度按时间r1wp621o1#
publishkafka处理器目前不允许您直接控制分区id。控制分区id的唯一方法是将“paritioner class”属性设置为“defaultpartitioner”，然后指定消息键。这将散列消息密钥以确定分区。