[
https://issues.apache.org/jira/browse/NIFI-1837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ralph Perko updated NIFI-1837:
------------------------------
Attachment: NIFI-1837.diff
decouple message delimiter from batch size
> PutKafka - Decouple incoming message delimiter from outgoing batching
> ---------------------------------------------------------------------
>
> Key: NIFI-1837
> URL: https://issues.apache.org/jira/browse/NIFI-1837
> Project: Apache NiFi
> Issue Type: Improvement
> Reporter: Ralph Perko
> Attachments: NIFI-1837.diff
>
>
> In 0.6.x batching outgoing messages to Kafka is only supported if a message
> delimiter is provided for incoming flow files. This appears to be a recently
> added constraint. It did not exist in 0.4.x. Could you please remove this.
> PutKafka.java:453
> Remove the "if" statement and just have:
> properties.setProperty("batch.size",
> context.getProperty(BATCH_NUM_MESSAGES).getValue());
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
