[fix][doc] Fix typos in class PersistentReplicator and PersistentDispatcherSingleActiveConsumer

Author: hanmz

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java

@@ -262,7 +262,7 @@ private synchronized void internalConsumerFlow(Consumer consumer) {
             }
         } else if (readOnActiveConsumerTask != null) {
             if (log.isDebugEnabled()) {
-                log.debug("[{}-{}] Ignoring flow control message since consumer is waiting for cursor to be rewinded",
+                log.debug("[{}-{}] Ignoring flow control message since consumer is waiting for cursor to be rewound",
                         name, consumer);
             }
         } else {
@@ -295,15 +295,15 @@ private synchronized void internalRedeliverUnacknowledgedMessages(Consumer consu
         }
 
         if (readOnActiveConsumerTask != null) {
-            log.info("[{}-{}] Ignoring reDeliverUnAcknowledgedMessages: consumer is waiting for cursor to be rewinded",
+            log.info("[{}-{}] Ignoring reDeliverUnAcknowledgedMessages: consumer is waiting for cursor to be rewound",
                     name, consumer);
             return;
         }
         cursor.cancelPendingReadRequest();
         havePendingRead = false;
         cursor.rewind(consumer.readCompacted());
         if (log.isDebugEnabled()) {
-            log.debug("[{}-{}] Cursor rewinded, redelivering unacknowledged messages. ", name, consumer);
+            log.debug("[{}-{}] Cursor rewound, redelivering unacknowledged messages. ", name, consumer);
         }
         readMoreEntries(consumer);
     }

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java

@@ -400,7 +400,7 @@ protected static final class ProducerSendCallback implements SendCallback {
         public void sendComplete(Throwable exception, OpSendMsgStats opSendMsgStats) {
             if (exception != null && !(exception instanceof PulsarClientException.InvalidMessageException)) {
                 log.error("[{}] Error producing on remote broker", replicator.replicatorId, exception);
-                // cursor should be rewinded since it was incremented when readMoreEntries
+                // cursor should be rewound since it was incremented when readMoreEntries
                 replicator.cursor.rewind();
             } else {
                 if (log.isDebugEnabled()) {