Запись в Кафке 0.10 идет с contentType даже после использования app.spring.cloud.stream.bindings.output.producer.headerMode = raw

Question

Я создал простой поток данных в весеннем облачном потоке, в котором http - источник, а kafka - приемник.

stream create --definition "http --port=<yyyy> --path-pattern=/test  > :streamtest1" --name ingest_to_broker_from_http --deploy --properties app.spring.cloud.stream.bindings.output.producer.headerMode=raw

Даже после использования app.spring.cloud.stream.bindings.output.producer.headerMode = raw , Я получаю сообщения Kafka со строкой приложения contentType.

Команда cURL:

curl -X POST -H "Content-Type: application/json" --data '{"name":"test6"}' http://<xxxx>:<yyyy>/test

Кафка Сообщение:

contentType "text / plain" originalContentType "Приложения / JSON; кодировка = UTF-8" { "имя": "test6"}

• Правильно ли передается свойство headerMode?
• Что я должен сделать, чтобы получать только сообщение (без заголовка) в Кафка в теме?

Answer 1

Разрешено.

Изменено свойство ниже:

app.http.spring.cloud.stream.bindings.output.producer.headerMode=raw