[ISSUE #608] Print message id and message queue when consume result i…

…s failure
apache · Sep 22, 2023 · c3972bb · c3972bb
1 parent 20c5fba
commit c3972bb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeTask.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeTask.java
@@ -63,7 +63,8 @@ public ConsumeResult call() {
         try {
             consumeResult = messageListener.consume(messageView);
         } catch (Throwable t) {
-            log.error("Message listener raised an exception while consuming messages, clientId={}", clientId, t);
+            log.error("Message listener raised an exception while consuming messages, clientId={}, mq={}, " +
+                "messageId={}", clientId, messageView.getMessageQueue(), messageView.getMessageId(), t);
             // If exception was thrown during the period of message consumption, mark it as failure.
             consumeResult = ConsumeResult.FAILURE;
         }