diff --git a/flink-format-changelog-json/src/main/java/com/ververica/cdc/formats/json/ChangelogJsonDeserializationSchema.java b/flink-format-changelog-json/src/main/java/com/ververica/cdc/formats/json/ChangelogJsonDeserializationSchema.java
index a137bad23..ff1f885e0 100644
--- a/flink-format-changelog-json/src/main/java/com/ververica/cdc/formats/json/ChangelogJsonDeserializationSchema.java
+++ b/flink-format-changelog-json/src/main/java/com/ververica/cdc/formats/json/ChangelogJsonDeserializationSchema.java
@@ -90,7 +90,7 @@ public class ChangelogJsonDeserializationSchema implements DeserializationSchema
             // a big try catch to protect the processing.
             if (!ignoreParseErrors) {
                 throw new IOException(
-                        format("Corrupt Debezium JSON message '%s'.", new String(bytes)), t);
+                        format("Corrupt Changelog JSON message '%s'.", new String(bytes)), t);
             }
         }
     }