Как правило, регистрировать динамические схемы protobuf в реестре схем kafka
Я реализовал множество конвейеров, которые производят прототипированные данные для kafka. Я хочу посмотреть, есть ли общий способ зарегистрировать каждый прото-файл, который использует другую схему с одной и той же функцией, без преобразования прото-сообщения в соответствующий объект Java, например, с помощью компилятора:
protoc -I=. --java_out=. my_proto.proto
Другими словами, есть ли способ зарегистрировать схему только через файл .proto так же, как зарегистрировать формат avro через файл avsc, но с форматом json?
Ответы 1
Нет. Реестр схем имеет четко определенный API на основе JSON и не принимает другие форматы схем.
https://docs.confluent.io/platform/current/schema-registry/develop/api.html
Однако вы можете попробовать использовать плагин Registry maven. В противном случае вам нужно написать собственный скрипт, чтобы JSON преобразовать прото-схему в полезную нагрузку, которую принимает реестр (имейте в виду, что это происходит автоматически, когда вы используете ProtobufSerializer из Confluent).