Как установить кластер реестра схемы kafka

Question

Я настроил кластер брокеров zookeeper и kafka. Я хочу настроить кластер реестра с несколькими схемами для аварийного переключения. Кластер Zookeeper с 3 узлами, кластер брокера Kafka с 3 узлами. Не могли бы вы подробно рассказать, как настроить реестр с несколькими схемами? Я использую конфлюентную версию 5.0

Заранее спасибо ?

Answer 1

Реестр схем разработан для работы в качестве распределенной службы с использованием единой главной архитектуры, поэтому в любой момент времени будет только один главный сервер, а остальные узлы будут работать как подчиненные, вы можете сослаться на арку реестра схем здесь

Вы можете выбрать кластер схемы-реестра из 3 узлов (вы можете запускать на тех же узлах вместе с zookeeper / Kafka). Поскольку вы используете конфлюент 5.0, вы можете использовать конфлюентный интерфейс командной строки,

confluent start schema-registry 

Обновите schema-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"

На стороне потребителя и производителя передайте список ulrs брокера реестра схем в Consumer.props & Produce.props

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

* По умолчанию порт реестра схемы будет 8081.

Надеюсь, это поможет.