hanmz opened a new issue, #21242:
URL: https://github.com/apache/pulsar/issues/21242

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/pulsar/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
   
   3、start geo-replication from cluster-2 to cluster-1
   
   4、We will encounter the following exception in cluster-2 broker log
   
![image](https://github.com/apache/pulsar/assets/16524922/676fc919-0d5e-400e-971f-f3c3f90035d4)
   
   
   ### 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: 
https://github.com/apache/pulsar/issues/21241
   
   
   In AbstractReplicator class, a possible solution is to replace 
Schema.AUTO_PRODUCE_BYTES() with Schema.BYTES?
   
   ### Are you willing to submit a PR?
   
   - [X] I'm willing to submit a PR!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to