Ralph Perko created NIFI-1837:
---------------------------------
Summary: 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
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)