don't throw and fail thread when topic not subscribed

NucleoTeam · Sep 27, 2024 · 7523603 · 7523603
1 parent 9aed643
commit 7523603
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/build.gradle b/build.gradle
@@ -7,7 +7,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.18.12'
+version = '1.18.13'
 
 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
@@ -176,7 +176,8 @@ public void run() {
                     getConsumer().poll(Duration.ofMillis(100));
                     Thread.sleep(1000);
                 } catch (InterruptedException e) {
-                    throw new RuntimeException(e);
+//                    throw new RuntimeException(e);
+                    e.printStackTrace();
                 }
             }
             seek(offsets);
@@ -189,7 +190,7 @@ public void run() {
                     Thread.sleep(1000);
                 } catch (InterruptedException e) {
                     e.printStackTrace();
-                    throw new RuntimeException(e);
+                    //throw new RuntimeException(e);
 
                 }
             }