如何通过Replicator传播Schema-Registry中的架构

Question

Confluent-Replicator如何将Confluent Schema-Registry中的模式传播到目标Kafka-Cluster和Schema-Registry？

是每个复制的消息模式都包含在其中，还是通过单独的主题以某种方式单独复制模式？

我在Confluent-Replicator中没有看到任何关于这一点的配置可能性。

Answer 1

听起来您好像在问如何在多数据中心环境中使用模式注册表。在这个https://docs.confluent.io/current/schema-registry/docs/multidc.html上有一个很好的医生

Replicator可用于保持后端模式注册表数据的同步，如文档所示。

Answer 2

模式不与主题一起存储，仅与其ID一起存储。并且不复制_schemas主题，仅将ID存储在复制的主题中。

在较高级别上，如果您将AvroConverter与Replicator一起使用，它将反序列化来自源群集的消息，根据replicator配置有选择地重命名主题，然后序列化消息并将新的主题名称发送到目标群集+注册表。

否则，如果您使用ByteArrayConverter，它将不会检查消息，而只是将其复制到目标群集，而不进行注册。

Avro方式上的一个小优化是，根据Schema Registry规范，只检查消息是否在前5个字节上Avro编码，然后使用Schema Registry REST API GET /schemas/ids/:id对源主题执行HTTP查找，如果需要，再次将主题重命名到目标集群，并在那里POST模式。类似的方法可以在任何消费者/生产者对中工作，例如MirrorMaker MessageHandler实现。