Как запустить два экземпляра реестра схемы - PullRequest
0 голосов
/ 27 июня 2018

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

Вот файл свойств для первого экземпляра реестра-схемы:

port=8081

# The address the socket server listens on.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
listeners=http://0.0.0.0:8081

# Zookeeper connection string for the Zookeeper cluster used by your Kafka cluster
# (see zookeeper docs for details).
# This is a comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
kafkastore.connection.url=localhost:2181,localhost:2182,localhost:2183

# Alternatively, Schema Registry can now operate without Zookeeper, handling all coordination via
# Kafka brokers. Use this setting to specify the bootstrap servers for your Kafka cluster and it
# will be used both for selecting the master schema registry instance and for storing the data for
# registered schemas.
# (Note that you cannot mix the two modes; use this mode only on new deployments or by shutting down
# all instances, switching to the new configuration, and then starting the schema registry
# instances again.)
#kafkastore.bootstrap.servers=localhost:9092

# The name of the topic to store schemas in
kafkastore.topic=_schemas

# If true, API requests that fail will include extra debugging information, including stack traces
debug=false

Как должен выглядеть второй файл, чтобы он мог взаимодействовать с zookeeper и достигать высокой доступности?

1 Ответ

0 голосов
/ 28 июня 2018

Вы можете использовать либо выборы лидера Кафки, либо выборы лидера Zookeeper.

Единственное, что вам нужно поменять между двумя экземплярами на одном компьютере, подключенном к одному и тому же Kafka / Zookeeper, - это свойство порта и слушателей

Чтобы правильно настроить высокую доступность, вам необходим балансировщик нагрузки HTTP для предоставления одного адреса для всех экземпляров.

...