我在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主题中只接收消息(没有标题)?
1条答案
按热度按时间ercv8c1e1#
断然的。
更改了以下属性: