[improve][java client] No need print exception stack when DLQ send failed.
@@ -2011,8 +2011,13 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
}
});
}).exceptionally(ex -> {
+ if (ex instanceof PulsarClientException.ProducerQueueIsFullError) {
+ log.warn("[{}] [{}] [{}] Failed to send DLQ message to {} for message id {}: {}",
+ topicName, subscription, consumerName, finalMessageId, ex.getMessage());
+ } else {
log.warn("[{}] [{}] [{}] Failed to send DLQ message to {} for message id {}",
topicName, subscription, consumerName, finalMessageId, ex);
+ }
result.complete(false);
return null;
});
