Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-4437: This closes #2183. When using ConsumeKafka_0_11 and no message demarcator, ensure that we add FlowFile Attributes for any Message Header that matches the 'Headers to Add as Attributes (Regex)' property 

Signed-off-by: joewitt <joewitt@apache.org>
This commit is contained in:
Mark Payne 2017-09-28 15:34:22 -04:00 committed by joewitt
parent 582df7f4e8
commit 7ad7520150
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
View File

@ -402,6 +402,7 @@ public abstract class ConsumerLease implements Closeable, ConsumerRebalanceListe
out.write(value); out.write(value);
}); });
} }
flowFile = session.putAllAttributes(flowFile, getAttributes(record));
tracker.updateFlowFile(flowFile); tracker.updateFlowFile(flowFile);
populateAttributes(tracker); populateAttributes(tracker);
session.transfer(tracker.flowFile, REL_SUCCESS); session.transfer(tracker.flowFile, REL_SUCCESS);