fixes #52 add deadLetterEnabled flag to the kafka-consumer.yml

networknt · May 10, 2021 · cd256e1 · cd256e1
1 parent 2e9eb85
commit cd256e1
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/kafka-common/src/main/java/com/networknt/kafka/common/KafkaConsumerConfig.java b/kafka-common/src/main/java/com/networknt/kafka/common/KafkaConsumerConfig.java
@@ -19,6 +19,7 @@ public class KafkaConsumerConfig {
     private String valueFormat;
     private String backendApiHost;
     private String backendApiPath;
+    private boolean deadLetterEnabled;
     private String deadLetterTopicExt;
     private boolean auditEnabled;
     private String auditTopic;
@@ -144,6 +145,14 @@ public String getBackendApiPath() {
         return backendApiPath;
     }
 
+    public boolean isDeadLetterEnabled() {
+        return deadLetterEnabled;
+    }
+
+    public void setDeadLetterEnabled(boolean deadLetterEnabled) {
+        this.deadLetterEnabled = deadLetterEnabled;
+    }
+
     public void setBackendApiPath(String backendApiPath) {
         this.backendApiPath = backendApiPath;
     }

diff --git a/kafka-common/src/test/resources/config/kafka-consumer.yml b/kafka-common/src/test/resources/config/kafka-consumer.yml
@@ -20,6 +20,8 @@ properties:
   # basic.auth.credentials.source: ${kafka-consumer.basic.auth.credentials.source:USER_INFO}
 
 # common configuration properties between active and reactive consumers
+# Indicator if the dead letter topic is enabled.
+deadLetterEnabled: ${kafka-consumer.deadLetterEnabled:true}
 # The extension of the dead letter queue(topic) that is added to the original topic to form the dead letter topic
 deadLetterTopicExt: ${kafka-consumer.deadLetterTopicExt:dlq}
 # Indicator if the audit is enabled.