fixed kafka node (success if error not null)

4 years ago · 19b5c59034
1 changed files with 1 additions and 1 deletions
--- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/kafka/TbKafkaNode.java
+++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/kafka/TbKafkaNode.java
@ -158,7 +158,7 @@ public class TbKafkaNode implements TbNode {
    }

    private void processRecord(TbContext ctx, TbMsg msg, RecordMetadata metadata, Exception e) {
-        if (metadata != null) {
+        if (e == null) {
            TbMsg next = processResponse(ctx, msg, metadata);
            ctx.tellNext(next, TbRelationTypes.SUCCESS);
        } else {