You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
CockroachDB changefeeds emit resolved timestamps across all the partitions within a topic. We could leverage it, to allow transactional consistency across multiple rows, by staging events and committed them to the target tables once we get the same resolved timestamp on all the partitions.
The text was updated successfully, but these errors were encountered:
This change adds transactional support to the Kafka connector for CRDB
changefeeds.
The changefeeds broadcast the resolved timestamp to each partition, and we
advance the checkpoint within cdc-sink based on the minimal resolved timestamp
received on all the partitions.
Closes#777.
This change adds transactional support to the Kafka connector for CRDB
changefeeds.
The changefeeds broadcast the resolved timestamp to each partition, and we
advance the checkpoint within cdc-sink based on the minimal resolved timestamp
received on all the partitions.
Closes#777.
This change adds transactional support to the Kafka connector for CRDB
changefeeds.
The changefeeds broadcast the resolved timestamp to each partition, and we
advance the checkpoint within cdc-sink based on the minimal resolved timestamp
received on all the partitions.
Closes#777.
CockroachDB changefeeds emit resolved timestamps across all the partitions within a topic. We could leverage it, to allow transactional consistency across multiple rows, by staging events and committed them to the target tables once we get the same resolved timestamp on all the partitions.
The text was updated successfully, but these errors were encountered: