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

    Details

      Description

      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.

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                bingqinzhou Bingqin Zhou
                Reporter:
                bingqinzhou Bingqin Zhou
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: