change log level

apache · Dec 20, 2024 · 40d6d84 · 40d6d84
1 parent c97b916
commit 40d6d84
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java
@@ -111,8 +111,8 @@ private void ackReceivedReplicatedMsg(ClientCnx cnx, OpSendMsg op, long sourceLI
         //   - The second time: Replicator --M1--> producer --> ...
         if (pendingLId < lastPersistedSourceLedgerId
                 || (pendingLId == lastPersistedSourceLedgerId  && pendingEId <= lastPersistedSourceEntryId)) {
-            if (log.isInfoEnabled()) {
-                log.info("[{}] [{}] Received an msg send receipt[pending send is repeated due to repl cursor rewind]:"
+            if (log.isDebugEnabled()) {
+                log.debug("[{}] [{}] Received an msg send receipt[pending send is repeated due to repl cursor rewind]:"
                                 + " source entry {}:{}, pending send: {}:{}, latest persisted: {}:{}",
                         topic, producerName, sourceLId, sourceEId, pendingLId, pendingEId,
                         lastPersistedSourceLedgerId, lastPersistedSourceEntryId);
@@ -129,8 +129,8 @@ private void ackReceivedReplicatedMsg(ClientCnx cnx, OpSendMsg op, long sourceLI
         //  - The second time: producer call Send-Command-1.
         if (sourceLId < lastPersistedSourceLedgerId
                 || (sourceLId == lastPersistedSourceLedgerId  && sourceEId <= lastPersistedSourceEntryId)) {
-            if (log.isInfoEnabled()) {
-                log.info("[{}] [{}] Received an msg send receipt[repeated]: source entry {}:{}, latest persisted:"
+            if (log.isDebugEnabled()) {
+                log.debug("[{}] [{}] Received an msg send receipt[repeated]: source entry {}:{}, latest persisted:"
                                 + " {}:{}",
                         topic, producerName, sourceLId, sourceEId,
                         lastPersistedSourceLedgerId, lastPersistedSourceEntryId);
@@ -140,8 +140,8 @@ private void ackReceivedReplicatedMsg(ClientCnx cnx, OpSendMsg op, long sourceLI
 
         // Case-3, which is expected.
         if (pendingLId != null && pendingEId != null && sourceLId == pendingLId && sourceEId == pendingEId) {
-            if (log.isInfoEnabled()) {
-                log.info("[{}] [{}] Received an msg send receipt[expected]: source entry {}:{}, target entry:"
+            if (log.isDebugEnabled()) {
+                log.debug("[{}] [{}] Received an msg send receipt[expected]: source entry {}:{}, target entry:"
                                 + " {}:{}",
                         topic, producerName, sourceLId, sourceEId,
                         targetLId, targetEid);
@@ -168,8 +168,8 @@ protected void ackReceivedReplMarker(ClientCnx cnx, OpSendMsg op, long seq, long
         long lastSeqPersisted = LAST_SEQ_ID_PUBLISHED_UPDATER.get(this);
         if (lastSeqPersisted != 0 && seq <= lastSeqPersisted) {
             // Ignoring the ack since it's referring to a message that has already timed out.
-            if (log.isInfoEnabled()) {
-                log.info("[{}] [{}] Received an repl marker send receipt[repeated]. seq: {}, seqPersisted: {},"
+            if (log.isDebugEnabled()) {
+                log.debug("[{}] [{}] Received an repl marker send receipt[repeated]. seq: {}, seqPersisted: {},"
                                 + " isSourceMarker: {}, target entry: {}:{}",
                         topic, producerName, seq, lastSeqPersisted, isSourceMarker, ledgerId, entryId);
             }
@@ -181,8 +181,8 @@ protected void ackReceivedReplMarker(ClientCnx cnx, OpSendMsg op, long seq, long
         //   and condition: the current pending msg is also a marker.
         boolean pendingMsgIsReplMarker = isReplicationMarker(op);
         if (pendingMsgIsReplMarker && seq == op.sequenceId) {
-            if (log.isInfoEnabled()) {
-                log.info("[{}] [{}] Received an repl marker send receipt[expected]. seq: {}, seqPersisted: {},"
+            if (log.isDebugEnabled()) {
+                log.debug("[{}] [{}] Received an repl marker send receipt[expected]. seq: {}, seqPersisted: {},"
                                 + " isReplMarker: {}, target entry: {}:{}",
                         topic, producerName, seq, lastSeqPersisted, isSourceMarker, ledgerId, entryId);
             }