From f0b2eb32db401a79fc0524fa2590ddeda5106c8a Mon Sep 17 00:00:00 2001 From: Adam Strickland Date: Mon, 28 Oct 2024 13:07:58 -0400 Subject: [PATCH] quiet the debug logs --- .../io/aiven/connect/jdbc/sink/BufferedRecords.java | 6 +++--- .../java/io/aiven/connect/jdbc/sink/DbStructure.java | 6 +++--- .../java/io/aiven/connect/jdbc/sink/JdbcDbWriter.java | 2 +- .../io/aiven/connect/jdbc/source/JdbcSourceTask.java | 10 +++++----- .../aiven/connect/jdbc/source/TableMonitorThread.java | 2 +- .../connect/jdbc/util/CachedConnectionProvider.java | 4 ++-- .../io/aiven/connect/jdbc/util/TableDefinitions.java | 4 ++-- 7 files changed, 17 insertions(+), 17 deletions(-) diff --git a/src/main/java/io/aiven/connect/jdbc/sink/BufferedRecords.java b/src/main/java/io/aiven/connect/jdbc/sink/BufferedRecords.java index 305db362..ad1b4e43 100644 --- a/src/main/java/io/aiven/connect/jdbc/sink/BufferedRecords.java +++ b/src/main/java/io/aiven/connect/jdbc/sink/BufferedRecords.java @@ -243,7 +243,7 @@ private void verifySuccessfulExecutions(final int totalSuccessfulExecutionCount, } if (successNoInfo) { - log.info("{} {} records:{} , but no count of the number of rows it affected is available", + log.debug("{} {} records:{} , but no count of the number of rows it affected is available", config.insertMode, recordType, batchRecords.size() @@ -296,13 +296,13 @@ private boolean isTombstone(final SinkRecord record) { } public void close() throws SQLException { - log.info("Closing BufferedRecords with preparedStatement: {}", preparedStatement); + log.debug("Closing BufferedRecords with preparedStatement: {}", preparedStatement); if (preparedStatement != null) { preparedStatement.close(); preparedStatement = null; } - log.info("Closing BufferedRecords with deletePreparedStatement: {}", deletePreparedStatement); + log.debug("Closing BufferedRecords with deletePreparedStatement: {}", deletePreparedStatement); if (deletePreparedStatement != null) { deletePreparedStatement.close(); deletePreparedStatement = null; diff --git a/src/main/java/io/aiven/connect/jdbc/sink/DbStructure.java b/src/main/java/io/aiven/connect/jdbc/sink/DbStructure.java index 93c13f36..8f4aa662 100644 --- a/src/main/java/io/aiven/connect/jdbc/sink/DbStructure.java +++ b/src/main/java/io/aiven/connect/jdbc/sink/DbStructure.java @@ -102,7 +102,7 @@ void create( ); } final String sql = dbDialect.buildCreateTableStatement(tableId, fieldsMetadata.allFields.values()); - log.info("Creating table with sql: {}", sql); + log.debug("Creating table with sql: {}", sql); dbDialect.applyDdlStatements(connection, Collections.singletonList(sql)); } @@ -159,7 +159,7 @@ boolean amendIfNecessary( } final List amendTableQueries = dbDialect.buildAlterTable(tableId, missingFields); - log.info( + log.debug( "Amending table to add missing fields:{} maxRetries:{} with SQL: {}", missingFields, maxRetries, @@ -231,7 +231,7 @@ Set missingFields( } if (missingFieldsIgnoreCase.size() > 0) { - log.info( + log.debug( "Unable to find fields {} among column names {}", missingFieldsIgnoreCase, dbColumnNames diff --git a/src/main/java/io/aiven/connect/jdbc/sink/JdbcDbWriter.java b/src/main/java/io/aiven/connect/jdbc/sink/JdbcDbWriter.java index 13b3af91..d2410dd2 100644 --- a/src/main/java/io/aiven/connect/jdbc/sink/JdbcDbWriter.java +++ b/src/main/java/io/aiven/connect/jdbc/sink/JdbcDbWriter.java @@ -57,7 +57,7 @@ public class JdbcDbWriter { this.cachedConnectionProvider = new CachedConnectionProvider(this.dbDialect) { @Override protected void onConnect(final Connection connection) throws SQLException { - log.info("JdbcDbWriter Connected"); + log.debug("JdbcDbWriter Connected"); connection.setAutoCommit(false); } }; diff --git a/src/main/java/io/aiven/connect/jdbc/source/JdbcSourceTask.java b/src/main/java/io/aiven/connect/jdbc/source/JdbcSourceTask.java index 7065f4fb..9e69964b 100644 --- a/src/main/java/io/aiven/connect/jdbc/source/JdbcSourceTask.java +++ b/src/main/java/io/aiven/connect/jdbc/source/JdbcSourceTask.java @@ -82,7 +82,7 @@ public String version() { @Override public void start(final Map properties) { - log.info("Starting JDBC source task"); + log.debug("Starting JDBC source task"); try { config = new JdbcSourceTaskConfig(properties); config.validate(); @@ -100,7 +100,7 @@ public void start(final Map properties) { final String connectionUrl = config.getConnectionUrl(); dialect = DatabaseDialects.findBestFor(connectionUrl, config); } - log.info("Using JDBC dialect {}", dialect.name()); + log.debug("Using JDBC dialect {}", dialect.name()); cachedConnectionProvider = new SourceConnectionProvider(dialect, maxConnAttempts, retryBackoff); @@ -253,7 +253,7 @@ public void start(final Map properties) { } running.set(true); - log.info("Started JDBC source task"); + log.debug("Started JDBC source task"); } //This method returns a list of possible partition maps for different offset protocols @@ -268,7 +268,7 @@ private List> possibleTablePartitions(final String table) { @Override public void stop() throws ConnectException { - log.info("Stopping JDBC source task"); + log.debug("Stopping JDBC source task"); running.set(false); // Wait for any in-progress polls to stop before closing resources // On older versions of Kafka Connect, SourceTask::stop and SourceTask::poll may @@ -281,7 +281,7 @@ public void stop() throws ConnectException { } protected void closeResources() { - log.info("Closing resources for JDBC source task"); + log.debug("Closing resources for JDBC source task"); try { if (cachedConnectionProvider != null) { cachedConnectionProvider.close(); diff --git a/src/main/java/io/aiven/connect/jdbc/source/TableMonitorThread.java b/src/main/java/io/aiven/connect/jdbc/source/TableMonitorThread.java index a58916d3..94e3efe6 100644 --- a/src/main/java/io/aiven/connect/jdbc/source/TableMonitorThread.java +++ b/src/main/java/io/aiven/connect/jdbc/source/TableMonitorThread.java @@ -194,7 +194,7 @@ private synchronized boolean updateTables() { } if (!newTables.equals(this.tables)) { - log.info( + log.debug( "After filtering the tables are: {}", dialect.expressionBuilder() .appendList() diff --git a/src/main/java/io/aiven/connect/jdbc/util/CachedConnectionProvider.java b/src/main/java/io/aiven/connect/jdbc/util/CachedConnectionProvider.java index 8d7faffd..e763b0eb 100644 --- a/src/main/java/io/aiven/connect/jdbc/util/CachedConnectionProvider.java +++ b/src/main/java/io/aiven/connect/jdbc/util/CachedConnectionProvider.java @@ -87,7 +87,7 @@ private void newConnection() throws SQLException { while (attempts < maxConnectionAttempts) { try { ++count; - log.info("Attempting to open connection #{} to {}", count, provider); + log.debug("Attempting to open connection #{} to {}", count, provider); connection = provider.getConnection(); onConnect(connection); return; @@ -113,7 +113,7 @@ private void newConnection() throws SQLException { public synchronized void close() { if (connection != null) { try { - log.info("Closing connection #{} to {}", count, provider); + log.debug("Closing connection #{} to {}", count, provider); connection.close(); } catch (final SQLException sqle) { log.warn("Ignoring error closing connection", sqle); diff --git a/src/main/java/io/aiven/connect/jdbc/util/TableDefinitions.java b/src/main/java/io/aiven/connect/jdbc/util/TableDefinitions.java index b352db0b..a6e62406 100644 --- a/src/main/java/io/aiven/connect/jdbc/util/TableDefinitions.java +++ b/src/main/java/io/aiven/connect/jdbc/util/TableDefinitions.java @@ -63,7 +63,7 @@ public TableDefinition get( if (dialect.tableExists(connection, tableId)) { dbTable = dialect.describeTable(connection, tableId); if (dbTable != null) { - log.info("Setting metadata for table {} to {}", tableId, dbTable); + log.debug("Setting metadata for table {} to {}", tableId, dbTable); cache.put(tableId, dbTable); } } @@ -84,7 +84,7 @@ public TableDefinition refresh( final TableId tableId ) throws SQLException { final TableDefinition dbTable = dialect.describeTable(connection, tableId); - log.info("Refreshing metadata for table {} to {}", tableId, dbTable); + log.debug("Refreshing metadata for table {} to {}", tableId, dbTable); cache.put(dbTable.id(), dbTable); return dbTable; }