diff --git a/tap_mysql/client.py b/tap_mysql/client.py
index cfad250..daa0e59 100644
--- a/tap_mysql/client.py
+++ b/tap_mysql/client.py
@@ -22,7 +22,7 @@
         "table_schema",
         "table_name",
         "column_name",
-        "data_type",
+        "column_type",
         "is_nullable",
         "column_key",
     ],
@@ -122,7 +122,7 @@ def create_catalog_entry(
 
             # Initialize columns list
             jsonschema_type: dict = self.to_jsonschema_type(
-                cast(sqlalchemy.types.TypeEngine, col.data_type),
+                cast(sqlalchemy.types.TypeEngine, col.column_type),
             )
             table_schema.append(
                 th.Property(
@@ -197,7 +197,7 @@ def discover_catalog_entries(self) -> list[dict]:
                     table_schema
                     , table_name
                     , column_name
-                    , data_type
+                    , column_type
                     , is_nullable
                     , column_key
                 FROM information_schema.columns