spring cloud stream 集成Kafka 接收到的消息内容前带contentType、application/json字符串

1、发送消息的代码:

this.source.output().send(MessageBuilder.withPayload("{'name':'zyy'}").setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON).build());

2、接受消息的代码:

@StreamListener(target = Sink.INPUT)
    public void onProductMsg(@Payload Object object) {
       System.out.println(object);
    }

3、结果:
图片说明

4、请教大家怎么去掉contentType、application/json字符串

查看全部
yidishui18414
yidishui18414
2019/04/25 09:04
  • spring
  • java
  • java-ee
  • 点赞
  • 收藏
  • 回答
    私信

1个回复