Как изменить схему данных тела confluent rest proxy для создания сообщений - PullRequest
Новая
       45

Как изменить схему данных тела confluent rest proxy для создания сообщений

0 голосов
/ 16 июня 2020

Слитные прокси-документы для отдыха предполагают, что для публикации данных они должны быть такими: 

$ curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" \
      --data '{"records":[{"value":{"name": "testUser"}}]}' \
      "http://localhost:8082/topics/jsontest"

а именно, все данные публикации должны быть заключены в следующую схему: 

{"records":[
    {"value":{<DATA>}}
]}

Мне было интересно, можно ли изменить эту схему? Например, я мог бы захотеть изменить записи в журнал и включить свои данные как внутри массива в качестве значения в журнал следующим образом: 

{"log": [<my_data>, <my_data>] }

Как я могу go об этом?

1 Ответ

0 голосов
/ 16 июня 2020

API определен в документации и указывает формат, который должна принимать ваша полезная нагрузка.

Если вы хотите объединить свои записи вместе, вам нужно сделать это в рамках определенной схемы, например, 

curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" \
      --data '{ "records": [ { "value": { "name": "testUser1" } }, { "value": { "name": "testUser2" } } ] }' \
      "http://localhost:8082/topics/jsontest"

AFAIK, единственный способ поддержать схему, о которой вы говорите, - это изменить исходный код самостоятельно.

...