-
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.