[NIFI-1837] PutKafka - Decouple incoming message delimiter from outgoing batching

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.6.1
• Fix Version/s: 1.0.0, 0.7.0, 1.0.0-Beta
• Labels: kafka
• Assignee: Oleg Zhurakousky
• Reporter: Ralph Perko
• Created: 02/May/16 19:15
• Updated: 04/Aug/16 21:29
• Resolved: 19/May/16 13:10

Description

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());