diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationTest.java
index cb4f8afa91..7cc8bb9397 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationTest.java
@@ -109,7 +109,7 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
       locator.addClusterTopologyListener(new ClusterTopologyListener() {
          @Override
          public void nodeUP(TopologyMember member, boolean last) {
-            logger.infof("nodeUP fired last=%s, live=%s, backup=%s", last, member.getLive(), member.getBackup());
+            logger.debugf("nodeUP fired last=%s, live=%s, backup=%s", last, member.getLive(), member.getBackup());
             if (member.getBackup() != null) {
                replicated.countDown();
             }
@@ -138,9 +138,9 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
                ClientMessage message = session.createMessage(true);
                // this will make journal's append executor busy
                message.putLongProperty("delay", 500L);
-               logger.infof("try to send a message before replicated");
+               logger.debugf("try to send a message before replicated");
                producer.send(message);
-               logger.info("send message done");
+               logger.debugf("send message done");
                producer.close();
                session.close();
 
@@ -168,9 +168,9 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
                ClientProducer producer = session.createProducer("slow");
                ClientMessage message = session.createMessage(true);
                message.putLongProperty("delay", 0L);
-               logger.infof("try to send a message after replicated");
+               logger.debugf("try to send a message after replicated");
                producer.send(message);
-               logger.info("send message done");
+               logger.debugf("send message done");
                producer.close();
                session.close();
 
@@ -204,7 +204,7 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
             if (!(info.userRecordType == JournalRecordIds.ADD_MESSAGE_PROTOCOL)) {
                // ignore
             }
-            logger.infof("got live message %d", info.id);
+            logger.debugf("got live message %d", info.id);
             liveJournalCounter.incrementAndGet();
          }
       });
@@ -224,12 +224,12 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
             if (!(info.userRecordType == JournalRecordIds.ADD_MESSAGE_PROTOCOL)) {
                // ignore
             }
-            logger.infof("replicated message %d", info.id);
+            logger.debugf("replicated message %d", info.id);
             replicationCounter.incrementAndGet();
          }
       });
 
-      logger.infof("expected %d messages, live=%d, backup=%d", j, liveJournalCounter.get(), replicationCounter.get());
+      logger.debugf("expected %d messages, live=%d, backup=%d", j, liveJournalCounter.get(), replicationCounter.get());
       Assert.assertEquals("Live lost journal record", j, liveJournalCounter.get());
       Assert.assertEquals("Backup did not replicated all journal", j, replicationCounter.get());
 
@@ -333,9 +333,9 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
          try {
             Long delay = record.getLongProperty("delay");
             if (delay == null || delay.longValue() <= 0) {
-               logger.infof("encode message %d, caller=%s", record.getMessageID(), Thread.currentThread().getName());
+               logger.debugf("encode message %d, caller=%s", record.getMessageID(), Thread.currentThread().getName());
             } else {
-               logger.infof("sleep %d ms before encode message %d, caller=%s", delay.longValue(), record.getMessageID(), Thread.currentThread().getName());
+               logger.debugf("sleep %d ms before encode message %d, caller=%s", delay.longValue(), record.getMessageID(), Thread.currentThread().getName());
                Thread.sleep(delay.longValue());
             }
          } catch (InterruptedException e) {