Using auto commit interval config via properties

sunbird-cb · Nov 10, 2022 · 886f0d0 · 886f0d0
1 parent 36fc315
commit 886f0d0
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/main/java/org/sunbird/core/config/ConsumerConfiguration.java b/src/main/java/org/sunbird/core/config/ConsumerConfiguration.java
@@ -29,6 +29,8 @@ public class ConsumerConfiguration {
     @Value("${kafka.max.poll.records}")
     private Integer kafkaMaxPollRecords;
 
+    @Value("${kafka.auto.commit.interval.ms}")
+    private Integer kafkaAutoCommitInterval;
 
     @Bean
     KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
@@ -52,7 +54,7 @@ public Map<String, Object> consumerConfigs() {
         propsMap.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkabootstrapAddress);
         propsMap.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);
         propsMap.put(ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG, "1000");
-        propsMap.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");
+        propsMap.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, kafkaAutoCommitInterval);
         propsMap.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "15000");
         propsMap.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
         propsMap.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);

diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -88,8 +88,9 @@ spring.kafka.bootstrap.servers=localhost:9092
 
 #kafka properties
 kakfa.offset.reset.value=latest
-kafka.max.poll.interval.ms=5000
+kafka.max.poll.interval.ms=15000
 kafka.max.poll.records=100
+kafka.auto.commit.interval.ms=10000
 
 org.create.endpoint=v1/org/create