1 files changed, 14 insertions, 0 deletions
diff --git a/sdc-distribution-client/src/main/java/org/onap/sdc/impl/Configuration.java b/sdc-distribution-client/src/main/java/org/onap/sdc/impl/Configuration.java
index 24f3225..dd67656 100644
--- a/sdc-distribution-client/src/main/java/org/onap/sdc/impl/Configuration.java
+++ b/sdc-distribution-client/src/main/java/org/onap/sdc/impl/Configuration.java
@@ -30,6 +30,8 @@ public class Configuration implements IConfiguration {
     private final String kafkaSecurityProtocolConfig;
     private final String kafkaSaslMechanism;
     private final String kafkaSaslJaasConfig;
+    private final int kafkaConsumerMaxPollInterval;
+    private final int kafkaConsumerSessionTimeout;
     private String sdcStatusTopicName;
     private String sdcNotificationTopicName;
     private String sdcAddress;
@@ -77,6 +79,8 @@ public class Configuration implements IConfiguration {
         this.httpsProxyHost = other.getHttpsProxyHost();
         this.httpsProxyPort = other.getHttpsProxyPort();
         this.useSystemProxy = other.isUseSystemProxy();
+        this.kafkaConsumerMaxPollInterval = other.getKafkaConsumerMaxPollInterval();
+        this.kafkaConsumerSessionTimeout = other.getKafkaConsumerSessionTimeout();
     }
 
     @Override
@@ -100,6 +104,16 @@ public class Configuration implements IConfiguration {
     }
 
     @Override
+    public int getKafkaConsumerMaxPollInterval() {
+        return kafkaConsumerMaxPollInterval;
+    }
+
+    @Override
+    public int getKafkaConsumerSessionTimeout() {
+        return kafkaConsumerSessionTimeout;
+    }
+
+    @Override
     public Boolean isUseHttpsWithSDC() {
         return useHttpsWithSDC;
     }