Блог

Главная - Вопросы по программированию - Как правильно передать вложенную схему protobuf в реестр схем слияния?

Как правильно передать вложенную схему protobuf в реестр схем слияния?

#protocol-buffers #confluent-platform #confluent-schema-registry

Вопрос:

Я использую интерфейс confluent rest-прокси для создания сообщения в формате Protobuf в тему Кафки. Это сообщение имеет вложенную структуру, в которой «Термин» состоит из одного или нескольких «Разделов», причем каждый «Раздел» имеет «идентификатор» и «имя». Вот как я отправляю это сообщение Кафке:

 curl -X POST -H "Content-Type: application/vnd.kafka.protobuf.v2 json" 
   -H "Accept: application/vnd.kafka.v2 json" 
   --data '{"value_schema": "syntax="proto3"; message Term {Sections [{string id = 1; string name = 2;}]}", "records": [{"value": [{"id": "123", "name": "Section-123"}]}]}' 
   "http://localhost:8082/topics/term"

Я получаю эту ошибку:

 {"error_code":42205,"message":"Invalid schema: Error when parsing raw schema. format = PROTOBUF, schema = syntax="proto3"; message Term {Sections [{string id = 1; string name = 2;}]}"}

Какие изменения я должен внести, чтобы это сработало?

Комментарии:

1. Вы нашли способ сделать это?

Метки: