Как получить все необходимые схемы Avro с учетом набора тем из реестра Confluent Schema - PullRequest
0 голосов
/ 06 июня 2018

Мы используем Kafka, Avro и Avro Schema Registry.Учитывая набор тем, которые я хочу использовать, есть ли способ получить все идентификаторы схемы, необходимые для декодирования сообщений, которые я получу?

Я проверил реализацию Confluent Pythonклиент и то, что делает , - это получение сообщений, получение идентификатора схемы Avro из отдельного сообщения, а затем поиск схемы в реестре схем Avro на лету.

Iищу способ получить все необходимые схемы до выполнения программы (т.е. вручную).

1 Ответ

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

Да, вы можете получить схему для любых данных темы

Остальные API -

GET /subjects/(string: subject)/versions

Получить список версий, зарегистрированных под указанной темой.Под темой понимается «-key» или «-value» в зависимости от того, регистрируете ли вы схему ключа для этой темы или схему значений

Получив версии схемы, вы можете получить схему длякаждая версия использует

GET /subjects/(string: subject)/versions/(versionId: version)/schema

Ссылка

https://docs.confluent.io/current/schema-registry/docs/api.html

...