commit 12fc10f4da4b2a51bd4a69bb8c3572bd9095ed3f
author Arpad Boda <aboda@apache.org> Thu Aug 20 21:10:03 2020 +0200
committer Marton Szasz <szaszm01@gmail.com> Thu Aug 20 21:10:03 2020 +0200
tree 1891bd860a7f611ab4629f2e982b3a147e5e8092
parent 4d218d97b7258c5cca01d65f3d4c69ad38405f1b

MINIFICPP-1333 PublishKafka should penalize flowfiles sent to failure

Signed-off-by: Marton Szasz <szaszm01@gmail.com>

extensions/librdkafka/PublishKafka.cpp

diff --git a/extensions/librdkafka/PublishKafka.cpp b/extensions/librdkafka/PublishKafka.cpp
index a6a3182..fc5ee56 100644
--- a/extensions/librdkafka/PublishKafka.cpp
+++ b/extensions/librdkafka/PublishKafka.cpp
@@ -701,6 +701,7 @@
     if (success) {
       session->transfer(flowFiles[index], Success);
     } else {
+      session->penalize(flowFiles[index]);
       session->transfer(flowFiles[index], Failure);
     }
   });