You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2023/08/31 08:18:26 UTC
[pulsar] branch master updated: [fix][client] Fix logging problem in pulsar client (#21094)
This is an automated email from the ASF dual-hosted git repository.
zixuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new eedbdb1a17f [fix][client] Fix logging problem in pulsar client (#21094)
eedbdb1a17f is described below
commit eedbdb1a17f627ded13af8082597cd660f13c4db
Author: 萧易客 <km...@live.com>
AuthorDate: Thu Aug 31 16:18:17 2023 +0800
[fix][client] Fix logging problem in pulsar client (#21094)
---
.../src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java | 6 +++---
1 file changed, 3 insertions(+), 3 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
index ef063c6b159..89670396458 100644
--- 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
@@ -421,7 +421,7 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
unsubscribeFuture.completeExceptionally(
PulsarClientException.wrap(e.getCause(),
String.format("Failed to unsubscribe the subscription %s of topic %s",
- topicName.toString(), subscription)));
+ subscription, topicName.toString())));
return null;
});
} else {
@@ -2501,9 +2501,9 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
return;
}
+ log.warn("[{}] [{}] Could not get connection while getLastMessageId -- Will try again in {} ms",
+ topic, getHandlerName(), nextDelay);
((ScheduledExecutorService) client.getScheduledExecutorProvider().getExecutor()).schedule(() -> {
- log.warn("[{}] [{}] Could not get connection while getLastMessageId -- Will try again in {} ms",
- topic, getHandlerName(), nextDelay);
remainingTime.addAndGet(-nextDelay);
internalGetLastMessageIdAsync(backoff, remainingTime, future);
}, nextDelay, TimeUnit.MILLISECONDS);