Есть ли способ создания сообщений Kafka с заголовками, используя Kafka Confluent REST API?

Question

Я пытаюсь отправить сообщения в Кафку с некоторыми пользовательскими заголовками, но я не смог найти способ сделать это.Согласно документации , API POST /topics/(string: topic_name) не имеет возможности прикреплять пользовательские заголовки к сообщениям.

Кто-нибудь знает способ отправки сообщений Kafka с пользовательскими заголовками через сливную Kafka?API REST?

Вот мое тело примера запроса, которое я отправил прокси REST

POST /topics/stream.mycustomtopic

{
    "records": [{
        "value": "{\"myFirstKey\":\"myFirstValue\"}"
    }]
}

Answer 1

Вы правы, REST-прокси в настоящее время не поддерживает заголовки Kafka. Вам нужно будет использовать Producer API для установки заголовков.