This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit eccacaff87dc14b0a702c1e211460a8fb25410a1 Author: Zhanpeng Wu <[email protected]> AuthorDate: Thu Nov 4 23:15:34 2021 +0800 Fix invalid firstSentAt value (#12588) (cherry picked from commit 2ca96e4e0e63f99af0b079f3d590bbc8aa179676) --- .../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java index 239ee60..fa7f364 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java @@ -1202,7 +1202,7 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne "%s : createdAt %s ns ago, firstSentAt %s ns ago, lastSentAt %s ns ago, retryCount %s", te.getMessage(), ns - this.createdAt, - ns - this.firstSentAt, + this.firstSentAt <= 0 ? ns - this.lastSentAt : ns - this.firstSentAt, ns - this.lastSentAt, retryCount );
