[
https://issues.apache.org/jira/browse/NIFI-6797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mark Payne updated NIFI-6797:
-----------------------------
Assignee: Mark Payne
Status: Patch Available (was: Open)
> 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
> Assignee: Mark Payne
> Priority: Major
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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)
