diff --git a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java index e7a16ab4e..e8c3bf514 100644 --- a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java +++ b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java @@ -134,7 +134,7 @@ private void markProcessed(SinkRecord record) { return; } - LOGGER.info("Marking processed record for topic {}", topicName); + LOGGER.trace("Marking processed record for topic {}", topicName); final TopicPartition topicPartition = new TopicPartition(topicName, record.kafkaPartition()); final OffsetAndMetadata offsetAndMetadata = new OffsetAndMetadata(record.kafkaOffset() + 1L);