When using AMQ Stream HTTP Bridge, it is not accepting message with headers information.
Issue
Referring Strimzi document (https://strimzi.io/docs/operators/latest/using.html#message_format); I am trying to put Kafka message headers.
curl -X POST \
http://localhost:8080/topics/my-topic \
-H 'content-type: application/vnd.kafka.json.v2+json' \
-d '{
"records": [
{
"key": "my-key",
"value": "my-value"
"partition": 2
"headers": [
{
"key": "key1",
"value": "value1"
}
]
},
]
}'
but I am getting the following response
{ "error_code": 400, "message": "Validation error on: body.records[0] - $.records[0].headers: is not defined in the schema and the schema does not allow additional properties" }
Environment
Red Hat AMQ Stream 1.5
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.