[Bug] [geo-replication] Failed to create remote producer (org.apache.avro.AvroRuntimeException: Not a record: "string")

[hanmz]

Search before asking

• I searched in the issues and found nothing similar.

Version

2.9.2 and above versions

Minimal reproduce step

1、create topic [test-tenant/test-ns/test-topic] in cluster-1 and cluster-2

2、send message by producer use Schema.JSON(String.class) in cluster-1
Producer<String> producer = client.newProducer(Schema.JSON(String.class)).topic("test-tenant/test-ns/test-topic").create();

3、start geo-replication from cluster-2 to cluster-1

4、We will encounter the following exception in cluster-2 broker log

What did you expect to see?

No exceptions and geo-replicator working normally.

What did you see instead?

Encountered an exception and was unable to normal work.

Anything else?

These two questions are similar: #21241

In AbstractReplicator class, a possible solution is to replace Schema.AUTO_PRODUCE_BYTES() with Schema.BYTES?

Are you willing to submit a PR?

• I'm willing to submit a PR!

[github-actions]

The issue had no activity for 30 days, mark with Stale label.