[
https://issues.apache.org/jira/browse/NIFI-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022258#comment-16022258
]
ASF subversion and git services commented on NIFI-3962:
-------------------------------------------------------
Commit 2c751a8e5bdf784513fabf1da029bb12cd076732 in nifi's branch
refs/heads/master from [~markap14]
[ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=2c751a8 ]
NIFI-3962: This closes #1846. Updated ConsumerLease to better handle batching
of messages into a single FlowFile in the same way that it is handled for
demarcated data
> Update ConsumeKafkaRecord_0_10 to better batch together messages into fewer
> flowfiles
> -------------------------------------------------------------------------------------
>
> Key: NIFI-3962
> URL: https://issues.apache.org/jira/browse/NIFI-3962
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Extensions
> Reporter: Mark Payne
> Assignee: Mark Payne
>
> Currently, ConsumeKafkaRecord will batch together only as many records in a
> FlowFile as it is able to obtain for a single partition & topic. This should
> be updated to allow for multiple iterations of KafkaConsumer.poll() in the
> same way that ConsumeKafka does with a Demarcator configured.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)