Transactional consistency using Kafka Connect

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!

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.