-
Bug
-
Resolution: Done
-
Critical
-
None
-
None
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.