Quick informal update: Plugging in an SMT works like a charm 👍. Thanks for pointing me in the right direction. Took some time to understand that the MirrorSinkConnector mentioned in the KIP doesn't actually exist in Kafka. When running MM2 as a "pure" MirrorSourceConnector I need to point the connector to the target cluster and not to the source cluster (sink vs source). This doesn't mesh perfectly with our planned setup (where our intention was to keep the replication config in the source cluster), but for our current message throughput this will certainly work.
/Anders On Tue, Sep 14, 2021 at 8:58 PM Ryanne Dolan <ryannedo...@gmail.com> wrote: > Yes it's a consequence of Connect, which has its own serde model. > > mirror-makers hard-coded ByteArraySerialization for > > consumers/producers >
