Fix the publish latency unit (#1405)

Author: Technoboy-

amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/AmqpEntryWriter.java

@@ -95,7 +95,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(position, false);
         context.positionFuture.complete(position);
         context.recycle();

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);
                 }