{ "type": "record", "name": "cassandra-cluster-1.inventory.customers.Value", "namespace": "io.debezium.connector.cassandra", "fields": [ { "name": "op", "type": "string" }, { "name": "ts_ms", "type": "long", "logicalType": "timestamp-millis" }, { "name": "after", "type": "record", "fields": [ { "name": "id", "type": [ "null", { "name": "id", "type": "record", "fields": [ { "name":"value", "type": "string" }, { "name":"deletion_ts", "type": ["null", "long"], "default" : "null" }, { "name":"set", "type": "boolean" } ] } ] }, { "name": "registration_date", "type": [ "null", { "name": "registration_date", "type": "record", "fields": [ { "name":"value", "type": "long", "logical_type": "timestamp-millis" }, { "name":"deletion_ts", "type": ["null", "long"], "default" : "null" }, { "name":"set", "type": "boolean" } ] } ] }, { "name": "first_name", "type": [ "null", { "name": "first_name", "type": "record", "fields": [ { "name":"value", "type": "string" }, { "name":"deletion_ts", "type": ["null", "long"], "default" : "null" }, { "name":"set", "type": "boolean" } ] } ] }, { "name": "last_name", "type": [ "null", { "name": "last_name", "type": "record", "fields": [ { "name":"value", "type": "string" }, { "name":"deletion_ts", "type": ["null", "long"], "default" : "null" }, { "name":"set", "type": "boolean" } ] } ] }, { "name": "last_name", "type": [ "null", { "name": "email", "type": "record", "fields": [ { "name":"value", "type": "string" }, { "name":"deletion_ts", "type": ["null", "long"], "default" : "null" }, { "name":"set", "type": "boolean" } ] } ] } ] }, { "name": "source", "type": "record", "fields": [ { "name": "version", "type": "string" }, { "name": "connector", "type": "string" }, { "name": "cluster", "type": "string" }, { "name": "snapshot", "type": "boolean" }, { "name": "keyspace", "type": "string" }, { "name": "table", "type": "string" }, { "name": "file", "type": "string" }, { "name": "position", "type": "int" }, { "name": "ts_micro", "type": "long", "logicalType": "timestamp-micros" } ] } ] }
Originally sourced from https://debezium.io/documentation/reference/connectors/cassandra.html