diff --git a/src/ziggurat/messaging/consumer.clj b/src/ziggurat/messaging/consumer.clj index 1f8c348e..5a32b9ac 100644 --- a/src/ziggurat/messaging/consumer.clj +++ b/src/ziggurat/messaging/consumer.clj @@ -196,7 +196,8 @@ handler (-> batch-route second :handler-fn) retry-subscribers (start-retry-subscriber* (fn [message] (ch/process handler message)) topic-entity)] (assoc subscriber-map topic-entity {:retry retry-subscribers}))) {} batch-routes) - data {:stream-consumers stream-consumers :batch-consumers batch-consumers}] + data {:stream-consumers stream-consumers :batch-consumers batch-consumers} + _ (log/info "Subscriber info" data)] data))) (defn stop-subscribers [subscribers additional-message]