即使在使用app.spring.cloud.stream.bindings.output.producer.headermode=raw之后,也可以在kafka 0.10中使用contenttype录制

ybzsozfc  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(506)

我在springclouddataflow中创建了一个简单的流,其中以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

Kafka信息:
contenttype“text/plain”originalcontenttype“应用程序/json;charset=utf-8“{”name“:”test6“}
我是否以正确的方式传递headermode属性?
我应该怎么做才能在Kafka主题中只接收消息(没有标题)?

ercv8c1e

ercv8c1e1#

断然的。
更改了以下属性:

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

相关问题