diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/DefaultReplicationWorker.java b/airbyte-workers/src/main/java/io/airbyte/workers/DefaultReplicationWorker.java
index 5369b3a329680..21d936266815b 100644
--- a/airbyte-workers/src/main/java/io/airbyte/workers/DefaultReplicationWorker.java
+++ b/airbyte-workers/src/main/java/io/airbyte/workers/DefaultReplicationWorker.java
@@ -201,8 +201,6 @@ private static Runnable getReplicationRunnable(Source<AirbyteMessage> source,
           if (messageOptional.isPresent()) {
             final AirbyteMessage message = mapper.mapMessage(messageOptional.get());
 
-            LOGGER.info("record in DefaultReplicationWorker: {}", message);
-
             sourceMessageTracker.accept(message);
             destination.accept(message);
           }