confluent-platform - 如何更改融合的休息代理正文数据模式以生成消息

Question

汇合的休息代理文件建议发布数据必须是这样的：

$ 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>] }

我该怎么办？

Answer 1

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 支持您正在谈论的架构的唯一方法是自己修改源代码。