fix offset settings for kafka

NucleoTeam · Jan 24, 2024 · 161cef0 · 161cef0
1 parent 0fb6c1f
commit 161cef0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/build.gradle b/build.gradle
@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.15.4'
+version = '1.15.5'
 
 repositories {
     mavenCentral()

diff --git a/src/main/java/com/nucleodb/library/mqs/kafka/KafkaSettings.java b/src/main/java/com/nucleodb/library/mqs/kafka/KafkaSettings.java
@@ -22,19 +22,15 @@ public KafkaSettings(Map<String, Object> objs) {
     if(objs.containsKey("groupName")) {
       this.groupName = (String) objs.get("groupName");
     }
-
     if(objs.containsKey("partitions")) {
       this.partitions = (int) objs.get("partitions");
     }
     if(objs.containsKey("replicas")) {
       this.replicas = (int) objs.get("replicas");
     }
-
     if(objs.containsKey("offsetReset")) {
-      this.replicas = (int) objs.get("offsetReset");
+      this.offsetReset = (String) objs.get("offsetReset");
     }
-
-
   }
 
   public String getGroupName() {