We are using Kafka Connect, Oracle CDC Source Connector, to create multiple table-specific topics.
If a change is made to multiple tables in a single transaction in Oracle DB, is there a way to then ensure that these changes are only consumed/joined as a single stream safely (using Kafka Streams or ksqlDB).
This is to ensure that the joined stream will never represent a state that didn’t exist in Oracle DB.
Thanks!