Ryan-Git

I don't think this this is possible...

As discussed, we could add a sequence number to the message with snowflake.

could you print the `key` (at mysqlstream/msg.go:475) so we can check why it fails? It seems there's some problem with xxhash.

I can't reproduce this with the following test added to mysqlstream/msg_test.go. Could you have a try? ```go func TestXXHash(t *testing.T) { r := require.New(t) key := [][]interface{}{ {"test", "sbtest10", "PRIMARY",...

You can delete the hashOptions to use default hasher, hopefully it could work. I've no idea for the root cause now.. what's your go version in production?

what can we do?

看具体需求。moha 是单主，但保证主备强一致（具体SLA要问下那边的同学）；gravity 可以双向同步，也就是支持多地写入（不同的记录），但在某个MySQL实例宕机时可能丢数据（与MySQL replication 一样）。

I think with change data capture, there's no need for a `outbox` collection, but anyway.. A new `output` simply works, but it seems too specialized. The listed fields determine two...

I wonder if there's any standard for the structure of outbox collection? `Ok, so I'll check it and add more details about the implementation here, what do you think?` I've...

> Need a new encoder which just returns a field's value as the event's payload(e.g, doc.value). yes if the consumer needed(don't want another pipeline to reshape data...) > Need a...