This is an automated email from the ASF dual-hosted git repository. yubiao pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push: new c7cffba6b62 [fix] [broker] error TimeUnit to record publish latency (#20074) c7cffba6b62 is described below commit c7cffba6b623183f82ec48c6c83a098dcd1a1fa8 Author: ken <1647023...@qq.com> AuthorDate: Thu Apr 13 01:22:02 2023 +0800 [fix] [broker] error TimeUnit to record publish latency (#20074) Co-authored-by: fanjianye <fanjia...@bigo.sg> Co-authored-by: tison <wander4...@gmail.com> (cherry picked from commit 547d792439e7b8bfefb0236b078ed145731da658) --- .../java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java index d7cee8b600b..3c9adbd3e4f 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java @@ -53,7 +53,7 @@ public class RestMessagePublishContext implements Topic.PublishContext { + "triggered send callback.", topic.getName(), ledgerId, entryId); } - topic.recordAddLatency(System.nanoTime() - startTimeNs, TimeUnit.MICROSECONDS); + topic.recordAddLatency(System.nanoTime() - startTimeNs, TimeUnit.NANOSECONDS); positionFuture.complete(PositionImpl.get(ledgerId, entryId)); } recycle();