[rocketmq-clients] branch master updated: [ISSUE #608] Print message id and message queue when consume result is failure (#609)

[zhouxzhan]

This is an automated email from the ASF dual-hosted git repository.

zhouxzhan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 92c627d5 [ISSUE #608] Print message id and message queue when consume 
result is failure (#609)
92c627d5 is described below

commit 92c627d55af415a5597ee9ea0efff27c313582b5
Author: Zhouxiang Zhan <zhouxz...@apache.org>
AuthorDate: Mon Sep 25 11:22:44 2023 +0800

    [ISSUE #608] Print message id and message queue when consume result is 
failure (#609)
---
 .../org/apache/rocketmq/client/java/impl/consumer/ConsumeTask.java     | 3 ++-
 1 file changed, 2 insertions(+), 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
index 90e34c5a..b1f5c7f2 100644
--- 
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 class ConsumeTask implements Callable<ConsumeResult> {
         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;
         }