fix reload consumer

NucleoTeam · Oct 2, 2024 · f73b00c · f73b00c
1 parent 8b42db8
commit f73b00c
Show file tree

Hide file tree

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

diff --git a/src/main/java/com/nucleodb/library/mqs/kafka/KafkaConsumerHandler.java b/src/main/java/com/nucleodb/library/mqs/kafka/KafkaConsumerHandler.java
@@ -386,7 +386,7 @@ public void run() {
         this.subscribe(new String[]{this.getSettings().getTable().toLowerCase()});
 
         if(isReloadConsumer()){
-            regularConsumer();
+            reloadConsumer();
             return;
         }