Mark Payne created NIFI-6797:
--------------------------------
Summary: PublishKafka* Processors should support a property for
Kafka Partition
Key: NIFI-6797
URL: https://issues.apache.org/jira/browse/NIFI-6797
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Reporter: Mark Payne
PublishKafka_* and PublishKafkaRecord_* processors do not provide the ability
to set the partition for each message. PublishKafka_* should support indicating
which partition a FlowFile goes to based on Expression Language (including
Attributes) and should use its own custom partitioner to handle that.
PublishKafkaRecord_* processors should do the same but should also support
using RecordPath to allow for sending records to different partitions.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
