NIFI-220: Added to provenance event number of events received
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/eaca6a29 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/eaca6a29 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/eaca6a29 Branch: refs/heads/NIFI-250 Commit: eaca6a29d3a33fcbe466c8aff87cc8ad3060b9e3 Parents: a77fb50 Author: Mark Payne <[email protected]> Authored: Tue Jan 13 19:28:53 2015 -0500 Committer: Mark Payne <[email protected]> Committed: Tue Jan 13 19:28:53 2015 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/processors/kafka/GetKafka.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/eaca6a29/nar-bundles/kafka-bundle/kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java ---------------------------------------------------------------------- diff --git a/nar-bundles/kafka-bundle/kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java b/nar-bundles/kafka-bundle/kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java index 8c6ca4c..f202e29 100644 --- a/nar-bundles/kafka-bundle/kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java +++ b/nar-bundles/kafka-bundle/kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java @@ -302,7 +302,7 @@ public class GetKafka extends AbstractProcessor { } else { flowFile = session.putAllAttributes(flowFile, attributes); final long millis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start); - session.getProvenanceReporter().receive(flowFile, "kafka://" + topic, millis); + session.getProvenanceReporter().receive(flowFile, "kafka://" + topic, "Received " + numMessages + " Kafka messages", millis); getLogger().info("Successfully received {} from Kafka with {} messages in {} millis", new Object[] {flowFile, numMessages, millis}); session.transfer(flowFile, REL_SUCCESS); }
