Mirror Maker 2 and Schema registry

Ops Cluster Replication
1

Hello,

I try to sync 2 clusters with Mirror Maker 2.
When I sync a topic from cluster A to B, I can see the new message in cluster B but it keeps the schema Id it has in cluster A.

To transfer schemas from A to B, I used a python script but couldn’t find a way to keep the same ids so they change between A and B.

So I try to transform the messages within Mirror Maker but can’t figure out how to change the schema Id in my transformation class.

here the code I use :

Schema schema = record.valueSchema();
if (schema != null) {
Map<String, String> parameters = schema.parameters();

parameters seems to be empty :frowning:

How can I transform the message with a new schema Id ? Or is it possible to sync schema registry and keep same Ids ?

Thanks for your help