Uncommenting WakeupException Log

gojek · Mar 2, 2021 · 1ec16ff · 1ec16ff
1 parent e68272b
commit 1ec16ff
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/ziggurat/kafka_consumer/consumer_handler.clj b/src/ziggurat/kafka_consumer/consumer_handler.clj
@@ -85,8 +85,7 @@
           (process handler-fn batch-payload)))
       (recur (seq (.poll consumer (Duration/ofMillis (or (:poll-timeout-ms-config consumer-config) DEFAULT_POLL_TIMEOUT_MS_CONFIG))))))
     (catch WakeupException e
-      ;(log/errorf e "WakeupException while polling for messages for: %s" topic-entity)
-      )
+      (log/errorf e "WakeupException while polling for messages for: %s" topic-entity))
     (catch Exception e
       (log/errorf e "Exception while polling for messages for: %s" topic-entity))
     (finally (do (log/info "Closing the Kafka Consumer for: " topic-entity)