diff --git a/CHANGES.txt b/CHANGES.txt
index ce89887db..4ea17cb18 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,5 +1,6 @@
 0.4.0
 -----
+ * Change log level for logs in CassandraSchema to debug level to avoid log spamming (CASSANALYTICS-149)
  * Pass SidecarCdcClient as a constructor parameter to avoid thread/resource leaks (CASSANALYTICS-142)
  * Support extended deletion time in CDC for Cassandra 5.0
  * Flush event consumer before persisting CDC state to prevent data loss on failure (CASSANALYTICS-126)
diff --git a/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java b/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java
index b2895a65f..bd4f2c78c 100644
--- a/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java
+++ b/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java
@@ -288,10 +288,14 @@ public static void updateCdcSchema(@NotNull Schema schema,
                                        @NotNull Partitioner partitioner,
                                        @NotNull TableIdLookup tableIdLookup)
     {
-        LOGGER.info("Updating CDC schema tables='{}'",
+        if (LOGGER.isDebugEnabled())
+        {
+            LOGGER.debug("Updating CDC schema tables='{}'",
                     cdcTables.stream()
                              .map(t -> String.format("%s.%s", t.keyspace(), t.table()))
                              .collect(Collectors.joining(",")));
+        }
+
         Map<String, Set<String>> cdcEnabledTables = CassandraSchema.cdcEnabledTables(schema);
         for (CqlTable table : cdcTables)
         {
@@ -301,7 +305,7 @@ public static void updateCdcSchema(@NotNull Schema schema,
             if (cdcEnabledTables.containsKey(table.keyspace()) && cdcEnabledTables.get(table.keyspace()).contains(table.table()))
             {
                 // table has cdc enabled already, update schema if it has changed
-                LOGGER.info("CDC already enabled keyspace={} table={}", table.keyspace(), table.table());
+                LOGGER.debug("CDC already enabled keyspace={} table={}", table.keyspace(), table.table());
                 cdcEnabledTables.get(table.keyspace()).remove(table.table());
                 CassandraSchema.maybeUpdateSchema(schema, partitioner, table, tableId, true);
                 Preconditions.checkArgument(CassandraSchema.isCdcEnabled(schema, table),