Repository: nifi Updated Branches: refs/heads/master 8000304e6 -> c3d54ab72
NIFI-1684 added penalization on failure Signed-off-by: joewitt <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/1292581e Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/1292581e Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/1292581e Branch: refs/heads/master Commit: 1292581ec822f7e595e037aad437c2bb837b83eb Parents: 8d960f5 Author: Oleg Zhurakousky <[email protected]> Authored: Thu Mar 24 15:29:35 2016 -0400 Committer: joewitt <[email protected]> Committed: Tue Mar 29 09:56:04 2016 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/processors/kafka/PutKafka.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/1292581e/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java index 513f4f3..44f04aa 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java @@ -306,7 +306,7 @@ public class PutKafka extends AbstractProcessor { session.transfer(flowFile, REL_SUCCESS); } else { flowFile = session.putAllAttributes(flowFile, this.buildFailedFlowFileAttributes(failedSegmentsRef.get(), messageContext)); - session.transfer(flowFile, REL_FAILURE); + session.transfer(session.penalize(flowFile), REL_FAILURE); } } else {
