[
https://issues.apache.org/jira/browse/NIFI-6797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Witt updated NIFI-6797:
---------------------------
Fix Version/s: (was: 1.11.0)
1.10.0
> 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
> Fix For: 1.10.0
>
> Time Spent: 40m
> 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)
