[
https://issues.apache.org/jira/browse/NIFI-6797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958167#comment-16958167
]
ASF subversion and git services commented on NIFI-6797:
-------------------------------------------------------
Commit 3543b9c42cb00b8365059a990aa4f77f23c4892b in nifi's branch
refs/heads/master from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=3543b9c ]
NIFI-6797: Add support for specifying Partition via EL or RecordPath for
PublishKafka(Record)_1_0 and PublishKafka(Record)_2_0
This closes #3834.
Signed-off-by: Bryan Bende <[email protected]>
> 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.11.0
>
> Time Spent: 0.5h
> 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)
