Skip to content

Commit f0b4a71

Browse files
TakaHiR07fanjianyetisonkun
authored andcommitted
[fix] [broker] error TimeUnit to record publish latency (#20074)
Co-authored-by: fanjianye <fanjianye@bigo.sg> Co-authored-by: tison <wander4096@gmail.com>
1 parent 3f3d7bf commit f0b4a71

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ public void completed(Exception exception, long ledgerId, long entryId) {
5353
+ "triggered send callback.",
5454
topic.getName(), ledgerId, entryId);
5555
}
56-
topic.recordAddLatency(System.nanoTime() - startTimeNs, TimeUnit.MICROSECONDS);
56+
topic.recordAddLatency(System.nanoTime() - startTimeNs, TimeUnit.NANOSECONDS);
5757
positionFuture.complete(PositionImpl.get(ledgerId, entryId));
5858
}
5959
recycle();

0 commit comments

Comments
 (0)