alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-6597 Reduce log verbosity

Browse Source
This commit is contained in:
mfvitale 2023-06-22 15:20:00 +02:00 committed by Chris Cranford
parent 250893070d
commit abc9ca6fdd
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java
View File

@ -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);