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字符串

生产者配置 headerMode=raw