Я хотел бы создать одно из значений атрибута в качестве partitionID для темы kafka.Например, мой список атрибутов файла потока имеет: account_number в качестве одного из атрибутов.И account_number can have different values eg, 111,222,121 etc.Тогда 111, 222, 121 etc будет PartitionID для моей темы kafka, так как я хочу получать сообщения, упорядоченные по метке времени.Я не могу найти никакой опции для этого в процессоре PublishKafka_0_10 в nifi.Заранее спасибо