DBZ-8053 Use debug log level

debezium · Jul 30, 2024 · 6f7e6de · 6f7e6de
1 parent 379f61e
commit 6f7e6de
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/io/debezium/connector/vitess/VitessMetadata.java b/src/main/java/io/debezium/connector/vitess/VitessMetadata.java
@@ -79,7 +79,7 @@ public List<String> getTables() {
     }
 
     private static void logResponse(Vtgate.ExecuteResponse response, String query) {
-        LOGGER.info("Got response: {} for query: {}", response, query);
+        LOGGER.debug("Got response: {} for query: {}", response, query);
     }
 
     private List<String> getVitessShards() {

diff --git a/src/main/java/io/debezium/connector/vitess/connection/VitessReplicationConnection.java b/src/main/java/io/debezium/connector/vitess/connection/VitessReplicationConnection.java
@@ -66,7 +66,7 @@ public VitessReplicationConnection(VitessConnectorConfig config, VitessDatabaseS
      * @throws StatusRuntimeException if the connection is not valid, or SQL statement can not be successfully exected
      */
     public Vtgate.ExecuteResponse execute(String sqlStatement) {
-        LOGGER.info("Executing sqlStament {}", sqlStatement);
+        LOGGER.debug("Executing sqlStament {}", sqlStatement);
         ManagedChannel channel = newChannel(config.getVtgateHost(), config.getVtgatePort(), config.getGrpcMaxInboundMessageSize());
         managedChannel.compareAndSet(null, channel);
 
@@ -83,7 +83,7 @@ public Vtgate.ExecuteResponse execute(String sqlStatement, String shard) {
 
         String target = String.format("%s:%s@%s", config.getKeyspace(), shard, config.getTabletType());
         Vtgate.Session session = Vtgate.Session.newBuilder().setTargetString(target).setAutocommit(true).build();
-        LOGGER.info("Autocommit {}", session.getAutocommit());
+        LOGGER.debug("Autocommit {}", session.getAutocommit());
         Vtgate.ExecuteRequest request = Vtgate.ExecuteRequest.newBuilder()
                 .setQuery(Proto.bindQuery(sqlStatement, Collections.emptyMap()))
                 .setSession(session)