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)

Reply via email to