Add debug statement to troubleshoot issues in prod

nirmata · Oct 21, 2022 · 5315a4d · 5315a4d
1 parent 2edf85a
commit 5315a4d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
 
     <groupId>com.nirmata.workflow</groupId>
     <artifactId>nirmata-workflow</artifactId>
-    <version>0.11.0</version>
+    <version>0.11.1</version>
 
     <properties>
         <jdk-version>17</jdk-version>

diff --git a/src/main/java/com/nirmata/workflow/queue/kafka/KafkaQueueConsumer.java b/src/main/java/com/nirmata/workflow/queue/kafka/KafkaQueueConsumer.java
@@ -253,16 +253,15 @@ private void runLoop() {
     private void submitToWorkerGently(ExecutableTask task) {
         boolean couldSubmit = false;
         // Submit to executor service with backpressure
-        for (int i = 0; !couldSubmit; i++) {
+        while (!couldSubmit) {
             try {
+                log.debug("KafkaQueueConsumer submitting task to workerservice {}", task);
                 executorWorkerService.submit(() -> taskRunner.executeTask(task));
                 couldSubmit = true;
             } catch (RejectedExecutionException ex) {
+                log.warn("Slow executors, and more work pumped in {}", task);
                 try {
                     Thread.sleep(1000);
-                    if (i % 10 == 0) {
-                        log.warn("Slow executors, and more work pumped in");
-                    }
                 } catch (InterruptedException _ex) {
                 }
             } catch (Exception ex) {