Illustration Image

Cassandra.Link

The best knowledge base on Apache Cassandra®

Helping platform leaders, architects, engineers, and operators build scalable real time data platforms.

12/9/2020

Reading time:1 min

Debezium Connector for Cassandra :: Debezium Documentation

by John Doe

{ "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" } ] } ]}

Illustration Image
{
  "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"
          }
        ]
      }
  ]
}

Related Articles

cassandra
event.driven
spark

Build an Event-Driven Architecture with Apache Kafka, Apache Spark, and Apache Cassandra

DataStax

8/3/2024

Checkout Planet Cassandra

Claim Your Free Planet Cassandra Contributor T-shirt!

Make your contribution and score a FREE Planet Cassandra Contributor T-Shirt! 
We value our incredible Cassandra community, and we want to express our gratitude by sending an exclusive Planet Cassandra Contributor T-Shirt you can wear with pride.

Join Our Newsletter!

Sign up below to receive email updates and see what's going on with our company

Explore Related Topics

AllKafkaSparkScyllaSStableKubernetesApiGithubGraphQl

Explore Further

cassandra