Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-1892

Kafka records from one Cassandra table get published to the kafka queue of another Cassandra table

XMLWordPrintable

      Seeing the following weird kafka message published from Cassandra-CDC:

      {
      	"ts_ms": 1583533623298,
      	"op": "i",
      	"source": {
      		"version": "1.1.0.Beta2",
      		"connector": "cassandra",
      		"name": "poc-cassandra02",
      		"ts_ms": 1578351649432,
      		"snapshot": {
      			"string": "true"
      		},
      		"db": "NULL",
      		"cluster": "POC TEST Cluster",
      		"file": "",
      		"pos": -1,
      		"keyspace": "test_cdc_agent",
      		"table": "tests"
      	},
      	"after": {
      		"id": {
      			"io.debezium.connector.cassandra.cassandra_cdc.test_cdc_agent.users.id": {
      				"value": {
      					"int": 1
      				},
      				"deletion_ts": null,
      				"set": true
      			}
      		},
      		"age": {
      			"io.debezium.connector.cassandra.cassandra_cdc.test_cdc_agent.users.age": {
      				"value": {
      					"int": 21
      				},
      				"deletion_ts": null,
      				"set": true
      			}
      		},
      		"category": {
      			"io.debezium.connector.cassandra.cassandra_cdc.test_cdc_agent.users.category": {
      				"value": {
      					"string": "cat_a"
      				},
      				"deletion_ts": null,
      				"set": true
      			}
      		}
      	}
      }
      

      It seems that some records from users table gets published to the kafka queue of tests table.

              zhou.bing@husky.neu.edu Bingqin Zhou (Inactive)
              zhou.bing@husky.neu.edu Bingqin Zhou (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: