diff --git a/s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/S3SourceTask.java b/s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/S3SourceTask.java
index 48f9a926..d2b2c44a 100644
--- a/s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/S3SourceTask.java
+++ b/s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/S3SourceTask.java
@@ -143,8 +143,8 @@ public void commit() {
 
     @Override
     public void commitRecord(final SourceRecord record) {
-        if (LOGGER.isInfoEnabled()) {
-            LOGGER.info("Committed individual record {}  committed", (Map<String, Object>) record.sourceOffset());
+        if (LOGGER.isDebugEnabled()) {
+            LOGGER.debug("Committed individual record {}  committed", (Map<String, Object>) record.sourceOffset());
         }
     }
 
diff --git a/s3-source-connector/src/test/java/io/aiven/kafka/connect/s3/source/S3SourceTaskTest.java b/s3-source-connector/src/test/java/io/aiven/kafka/connect/s3/source/S3SourceTaskTest.java
index ea510a22..6a1a8157 100644
--- a/s3-source-connector/src/test/java/io/aiven/kafka/connect/s3/source/S3SourceTaskTest.java
+++ b/s3-source-connector/src/test/java/io/aiven/kafka/connect/s3/source/S3SourceTaskTest.java
@@ -125,8 +125,6 @@ public static void tearDownClass() {
     public void setUp() {
         properties = new HashMap<>(commonProperties);
         s3Client.createBucket(create -> create.bucket(TEST_BUCKET).build());
-        // mockedSourceTaskContext = mock(SourceTaskContext.class);
-        // mockedOffsetStorageReader = mock(OffsetStorageReader.class);
     }
 
     @AfterEach