Description
Hi
I submit here my question perhaps it is note the right place.
But we use REST PROXY to produce records, such as this below
curl --location 'https:///topics/<topic_name>'
--header 'Content-Type: application/vnd.kafka.json.v2+json'
--header 'Accept: application/vnd.kafka.v2+json, application/vnd.kafka+json, application/json'
--header 'Authorization: Basic dXNlcmFkbWluOmJyazFmdmcqeGFyLmFybkBKUlk='
--data '{ "key_schema_id": 100416,
"value_schema_id": 120074,
"records": [
{
"key": {
"data": {
"externalOfferId": "XXX",
"contextCode": "XXX",
"sourceAppId": "XXX"
}
},
"value": {
"data": {
"order": {
"externalOfferId": "XXX",
"contextCode": "XXX",
"priceContextCode": {
"string": "XXX"
},
"status": "UPDATED",
"externalVersionId": ""
},....
But we receiveve this error
{
"offsets": [
{
"partition": null,
"offset": null,
"error_code": 50002,
"error": "Record DefaultRecord(offset=0, timestamp=1686753735480, key=121 bytes, value=1956 bytes) is rejected by the record interceptor io.confluent.cloud.kafka.schemaregistry.validator.CloudRecordSchemaValidator"
}
],
"key_schema_id": null,
"value_schema_id": null
}
I saw that there was perhaps a bug (https://forum.confluent.io/t/json-payload-with-schema-validation-on-kafka-rest-proxy/7380 )
May I am right?
Do we have to use insteadd V3 and bulk ?
Thanks in advance for the help
Best Regards