diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
index 7b44ad544..f67824a6d 100644
--- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
+++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
@@ -75,6 +75,7 @@ public class QueueConsumer implements AutoCloseable {
     }
 
     public void init() {
+        final Exception debugCallerStacktrace = new Exception("init call");
         inputExecutor.submit(() -> {
             try {
                 log.debug("Using kafka consumer {} for subscribe on \"{}\"", consumer, callbacks.keySet());
@@ -128,7 +129,8 @@ public class QueueConsumer implements AutoCloseable {
             } catch (WakeupException e) {
                 if (!closed.get()) throw e;
             } catch (Throwable e) {
-                log.error(ExceptionUtils.getStackTrace(e));
+                log.error("QueueConsumer error: {}; main thread stacktrace: {}",
+                        ExceptionUtils.getStackTrace(e), ExceptionUtils.getStackTrace(debugCallerStacktrace));
             } finally {
                 consumer.close();
             }