replicator

replicator copied to clipboard

CockroachDB changefeeds can be emitted in avro format, leveraging a schema registry. The Kafka connector in replicator could accept avro in addition to JSON.

sravotto

This is the top-level tracking issue for work related to implementing a three-way merge operation. Plan: * [x] #509 (Use this issue for design discussion) * Receive and persist changefeed...

bobvawter

We likely have collections and types that could take advantage of the new, generic, collection APIs that are available in current SDKs.

bobvawter

bobvawter

https://tip.golang.org/doc/go1.22 see section "References to loop variables"

bobvawter

https://tip.golang.org/doc/go1.22 see section "Enhanced routing patterns"

bobvawter

If we're adding an entry to a DLQ table due to a merge conflict, we should add an extra JSON blob containing the before/after/target values for each conflicting property (we...

bobvawter

DB2 connector - Feature Preview

1

This change adds a connector to a DB2 database source. It uses DB2 SQL replication, leveraging staging tables in the source database. For instructions on how to put tables in...

sravotto

Right now, CAS requires a column for comparison, so we sometimes add a bogus column just to trigger three-way merges. If there were an "always" option for CAS, we could...

bobvawter

Add command to force-apply missed mutations

1

It would be useful to have a maintenance command to force cdc-sink to sweep for missed or otherwise unapplied mutations in a staging table.

bobvawter