1

avro ペイロードを kafka-rest サービスに発行するときに、value_schema のフィールドの 1 つがデフォルト値で定義され、records でこのフィールドが省略されている場合。kafka-rest はまだレコード内に保持することを主張しているようです。そうする正しい方法は何ですか？

例えば。

curl -X POST -H "Content-Type: application/vnd.kafka.avro.v1+json" \
  --data '{"value_schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}, {\"name\":\"age\",\"type\":\"int\",\"default\":18}, {\"name\":\"id\",\"type\":\"string\"}]}", "records": [{"value": {"name": "testUser", "id": "001"}}]}' \
  "http://localhost:8082/topics/avrotest"

出力

{"error_code":42203,"message":"Conversion of JSON to Avro failed: Failed to convert JSON to Avro: Expected field name not found: age"}
4

0 に答える 0