Как потребитель может проверить, доступен ли реестр схемы, прежде чем получать данные от брокера Kafka? - PullRequest
1 голос
/ 31 октября 2019

Как я знаю, потребитель Kafka перейдет в реестр схем для извлечения и кэширования схемы данных для будущего использования при первой десериализации данных avro от брокера.

Возможно ли, чтобы потребительский процесс сначала проверил, доступен ли реестр схемы (например, проблема с сетью или случайный сбой реестра или что-то еще), прежде чем все это начнется?

1 Ответ

1 голос
/ 31 октября 2019

Вы можете использовать класс CachedSchemaRegistryClient или HttpURLConnection вне цикла Consumer для создания HTTP-соединения.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...