diff --git a/debezium-server/debezium-server-ybexporter/src/main/java/io/debezium/server/ybexporter/YbExporterConsumer.java b/debezium-server/debezium-server-ybexporter/src/main/java/io/debezium/server/ybexporter/YbExporterConsumer.java
index 367e4cdee65..f666a4dfdc8 100644
--- a/debezium-server/debezium-server-ybexporter/src/main/java/io/debezium/server/ybexporter/YbExporterConsumer.java
+++ b/debezium-server/debezium-server-ybexporter/src/main/java/io/debezium/server/ybexporter/YbExporterConsumer.java
@@ -225,7 +225,8 @@ public void handleBatch(List<ChangeEvent<Object, Object>> changeEvents, Debezium
             checkIfSnapshotComplete(r);
         }
         handleBatchComplete();
-        LOGGER.info("Fsynced batch with {} records", changeEvents.size());
+
+        LOGGER.debug("Fsynced batch with {} records", changeEvents.size());
 
         // committer.markProcessed(event) updates offsets in memory, committer.MarkBatchFinished flushes those
         // offsets to disk. Offsets are also flushed to disk when debezium-server is gracefully shutdown. (which can
@@ -238,7 +239,7 @@ public void handleBatch(List<ChangeEvent<Object, Object>> changeEvents, Debezium
             committer.markProcessed(event);
         }
         committer.markBatchFinished();
-        LOGGER.info("Committed batch complete with {} records", changeEvents.size());
+        LOGGER.debug("Committed batch complete with {} records", changeEvents.size());
         handleSnapshotOnlyComplete();
     }