Mark Payne created NIFI-3962: -------------------------------- Summary: 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
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)