Fix the publish latency unit (#1405)

(cherry picked from commit 423ae3e)
streamnative · Oct 29, 2024 · 05ffe1e · 05ffe1e
1 parent 5e2dbb6
commit 05ffe1e
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/AmqpEntryWriter.java b/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/AmqpEntryWriter.java
@@ -96,7 +96,7 @@ public void addComplete(Position position, ByteBuf entryData, Object ctx) {
         if (log.isDebugEnabled()) {
             log.debug("[{}] Success to write entry with position {}.", topic.getName(), position);
         }
-        topic.recordAddLatency(System.nanoTime() - context.startTimeNs, TimeUnit.MICROSECONDS);
+        topic.recordAddLatency(System.nanoTime() - context.startTimeNs, TimeUnit.NANOSECONDS);
         topic.getTransactionBuffer().syncMaxReadPositionForNormalPublish((PositionImpl) position, false);
         context.positionFuture.complete(position);
         context.recycle();

diff --git a/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/AmqpExchangeReplicator.java b/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/AmqpExchangeReplicator.java
@@ -190,7 +190,6 @@ private void readMoreEntries() {
             messagesToRead = Math.max(messagesToRead, 1);
 
             if (HAVE_PENDING_READ_UPDATER.compareAndSet(this, FALSE, TRUE)) {
-                log.info("{} Schedule read of {} messages.", name, messagesToRead);
                 if (log.isDebugEnabled()) {
                     log.debug("{} Schedule read of {} messages.", name, messagesToRead);
                 }