Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.6.1
-
None
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());