Changes as per review

Aiven-Open · Jan 7, 2025 · da17e1f · da17e1f
1 parent 0edf114
commit da17e1f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
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
@@ -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
@@ -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