| MySQL | Kafka Connect |
ClickHouse |
|---|---|---|
| Bigint | INT64_SCHEMA | Int64 |
| Bigint Unsigned | INT64_SCHEMA | UInt64 |
| Blob | String + hex | |
| Char | String | String / LowCardinality(String) |
| Date | Schema: INT64 Name: debezium.Date |
Date or String |
| DateTime(6) | Schema: INT64 Name: debezium.Timestamp |
DateTime64(6) or String |
| Decimal(30,12) | Schema: Bytes Name: kafka.connect.data.Decimal |
Decimal(30,12) |
| Double | Float64 | |
| Int | INT32 | Int32 |
| Int Unsigned | INT64 | UInt32 |
| Longblob | String + hex | |
| Mediumblob | String + hex | |
| Mediumint | INT32 | Int32 |
| Mediumint Unsigned | INT32 | UInt32 |
| Smallint | INT16 | Int16 |
| Smallint Unsigned | INT32 | UInt16 |
| Text | String | String |
| Time | String | |
| Time(6) | String | |
| Timestamp | DateTime | |
| Tinyint | INT16 | Int8 |
| Tinyint Unsigned | INT16 | UInt8 |
| varbinary(*) | String + hex | |
| varchar(*) | String | |