output info for topic creation

NucleoTeam · Jan 24, 2024 · 2935f4e · 2935f4e
1 parent 0f07581
commit 2935f4e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/build.gradle b/build.gradle
@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.15.6'
+version = '1.15.7'
 
 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
@@ -85,8 +85,7 @@ public void createTopics() {
           f.printStackTrace();
         }
         if (names.stream().filter(name -> name.equals(topic)).count() == 0) {
-          logger.info("topic not created");
-          System.exit(-1);
+          logger.severe("topic not created "+topic);
         }
         countDownLatchCreatedCheck.countDown();
       });

diff --git a/src/main/java/com/nucleodb/library/mqs/kafka/KafkaProducerHandler.java b/src/main/java/com/nucleodb/library/mqs/kafka/KafkaProducerHandler.java
@@ -77,7 +77,9 @@ public void createTopics() {
                     createTopicsResult.all().whenComplete((c, e) -> {
                         if (e != null) {
                             e.printStackTrace();
+                            logger.severe(e.getMessage());
                         }
+
                         countDownLatch.countDown();
                     });
                 }else{
@@ -96,10 +98,10 @@ public void createTopics() {
             listTopicsResult.names().whenComplete((names, f)->{
                 if(f!=null){
                     f.printStackTrace();
+                    logger.severe(f.getMessage());
                 }
                 if (names.stream().filter(name -> name.equals(topic)).count() == 0) {
-                    logger.info("topic not created");
-                    System.exit(-1);
+                    logger.severe("topic not created "+topic);
                 }
                 countDownLatchCreatedCheck.countDown();
             });