From da17e1f742e523c16c7a3091a0f83978c627fce5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C2=A8Claude?= <¨claude.warren@aiven.io¨> Date: Tue, 7 Jan 2025 15:05:11 +0000 Subject: [PATCH] Changes as per review --- .../java/io/aiven/kafka/connect/s3/source/S3SourceTask.java | 4 ++-- .../io/aiven/kafka/connect/s3/source/S3SourceTaskTest.java | 2 -- 2 files changed, 2 insertions(+), 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 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) record.sourceOffset()); + if (LOGGER.isDebugEnabled()) { + LOGGER.debug("Committed individual record {} committed", (Map) 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