Согласно этой статье:
https://www.confluent.io/blog/elastic-scaling-in-kafka-streams/
Экземпляры приложения в Apache Kafka генерируются автоматически в зависимости от количества разделов, которые есть в теме ввода. (Тема ввода в соответствии с топологией рассматриваемой заявки).
Я не могу понять, как отображаются конечные точки RPC для этих автоматически генерируемых экземпляров приложения.
Мой вопрос касается использования Apache Kafka в кластере, где каждый экземпляр приложения автоматически запускается на другой машине кластера.
Согласно документации :
Чтобы включить обнаружение удаленного хранилища состояний в распределенных потоках Kafka
приложение, вы должны установить свойство конфигурации в конфигурации
свойства экземпляра. Свойство application.server определяет уникальный
host: пара портов, указывающая на конечную точку RPC соответствующего
экземпляр приложения Kafka Streams. Ценность этого
свойство конфигурации будет варьироваться в зависимости от вашего
приложение. Когда это свойство установлено, Kafka Streams будет отслеживать
информации конечной точки RPC для каждого экземпляра приложения,
его хранилища состояний и назначенные потоковые разделы через экземпляры
StreamsMetadata.
Я не могу сказать, как я выставляю конечную точку RPC для каждого экземпляра, так как я априори не знаю, сколько экземпляров будет в моем приложении.
Почему документация гласит:
Значение этого свойства конфигурации будет варьироваться в зависимости от
экземпляры вашего заявления.
поскольку число экземпляров генерируется автоматически, и как мне установить свойство application.server для каждого экземпляра приложения?
(В KafkaMusicExample каждый экземпляр приложения предоставляет случайные конечные точки RPC на том же компьютере, как показано здесь )
Таким образом, мой вопрос заключается в том, все ли экземпляры используют одно имя хоста и порт для вызовов RPC или я должен настроить отдельную конечную точку RPC для каждого автоматически сгенерированного экземпляра каким-либо образом в кластере и как я получаю доступ к имени хоста каждого из них автоматически сгенерированный экземпляр приложения в кластере?