如何设置kafka schema registry cluster

Question

我已经搭建了zookeeper和kafka broker集群。我想设置多个模式注册表集群以进行故障转移。具有 3 个节点的 Zookeeper 集群具有 3 个节点的 kafka 代理集群。

您能否提及如何设置多模式注册表的详细步骤？

我使用的是confluent 5.0版本

Answer 1

Schema Registry 被设计为使用单主架构的分布式服务，因此在任何给定时间都只有一个主节点，其余节点引用它。您可以参考架构注册表 here

您可以选择 3 节点模式注册表集群（您可以运行与 zookeeper/Kafka 在相同的节点上），因为您使用的是 confluent 5.0，所以您可以使用 confluent CLI，

confluent start schema-registry

更新架构-registry.properties,

 #zookeeper urls
 kafkastore.connection.url=zookeeper-1:2181,zookeeper-2:2181,...
 #make every node eligible to become master for failover 
 master.eligibility=true

在消费者和生产者方面，在 Consumer.props & Produce.props

中传递架构注册 url 列表

props.put("schema.registry.url","http://schemaregistry-1:8081,http://schemaregistry-2:8081,http://schemaregistry-3:8081")

*默认模式注册端口为 8081。

希望这对您有所帮助。

如何设置kafka schema registry cluster

How to set kafka schema registry cluster

apache-kafka

confluent-schema-registry