[fix][client] Logger.warn usage bug fix: the number is inconsistent f…

…or format and arguments (#19562) Co-authored-by: lushiji <[email protected]>
apache · Feb 20, 2023 · e0b50c9 · e0b50c9
1 parent 3855585
commit e0b50c9
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
@@ -2028,10 +2028,12 @@ private CompletableFuture<Boolean> processPossibleToDLQ(MessageIdImpl messageId)
                             }).exceptionally(ex -> {
                                 if (ex instanceof PulsarClientException.ProducerQueueIsFullError) {
                                     log.warn("[{}] [{}] [{}] Failed to send DLQ message to {} for message id {}: {}",
-                                            topicName, subscription, consumerName, finalMessageId, ex.getMessage());
+                                            topicName, subscription, consumerName,
+                                            deadLetterPolicy.getDeadLetterTopic(), finalMessageId, ex.getMessage());
                                 } else {
                                     log.warn("[{}] [{}] [{}] Failed to send DLQ message to {} for message id {}",
-                                            topicName, subscription, consumerName, finalMessageId, ex);
+                                            topicName, subscription, consumerName,
+                                            deadLetterPolicy.getDeadLetterTopic(), finalMessageId, ex);
                                 }
                                 result.complete(false);
                                 return null;