即使在使用 app.spring.cloud.stream.bindings.output.producer.headerMode=raw 之后，在 Kafka 0.10 中记录也带有 contentType
Record in Kafka 0.10 coming with contentType even after using app.spring.cloud.stream.bindings.output.producer.headerMode=raw
我在 spring 云数据流中创建了一个简单的流，其中我将 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 之后，
我正在接收带有 contentType 应用程序字符串的 Kafka 消息。
cURL 命令：
curl -X POST -H "Content-Type: application/json" --data '{"name":"test6"}' http://<xxxx>:<yyyy>/test
卡夫卡消息：
contentType "text/plain"originalContentType
"application/json;charset=UTF-8"{"name":"test6"}
- 我是否以正确的方式通过了header模式属性？
- 我应该怎么做才能只收到消息（没有header）
Kafka 主题？
已解决。
更改了以下 属性:
app.http.spring.cloud.stream.bindings.output.producer.headerMode=raw
我在 spring 云数据流中创建了一个简单的流，其中我将 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 之后， 我正在接收带有 contentType 应用程序字符串的 Kafka 消息。
cURL 命令：
curl -X POST -H "Content-Type: application/json" --data '{"name":"test6"}' http://<xxxx>:<yyyy>/test
卡夫卡消息：
contentType "text/plain"originalContentType "application/json;charset=UTF-8"{"name":"test6"}
- 我是否以正确的方式通过了header模式属性？
- 我应该怎么做才能只收到消息（没有header） Kafka 主题？
已解决。
更改了以下 属性:
app.http.spring.cloud.stream.bindings.output.producer.headerMode=raw