diff --git a/build.gradle b/build.gradle
index 35ca034..8a93fa6 100644
--- 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
index aae5d1a..1864104 100644
--- 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;
         }