MINOR: logs when Streams is done closing down

and pads my commit count
littlehorse-enterprises · May 17, 2024 · c8ba664 · c8ba664
1 parent 7b120ed
commit c8ba664
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/server/src/main/java/io/littlehorse/server/KafkaStreamsServerImpl.java b/server/src/main/java/io/littlehorse/server/KafkaStreamsServerImpl.java
@@ -1043,13 +1043,15 @@ public void close() {
                     log.info("Closing timer");
                     timerStreams.close();
                     latch.countDown();
+                    log.info("Done closing timer Kafka Streams");
                 })
                 .start();
 
         new Thread(() -> {
                     log.info("Closing core");
                     coreStreams.close();
                     latch.countDown();
+                    log.info("Done closing core Kafka Streams");
                 })
                 .start();
 
@@ -1072,6 +1074,7 @@ public void close() {
 
         try {
             latch.await();
+            log.info("Done shutting down all internal server processes");
         } catch (Exception exn) {
             throw new RuntimeException(exn);
         }