我想建立一个Spring云流Kafka生产者与 Spring 启动。
生产者正在工作，我可以使用来自kafka代理的消息，但是消息还包含一些头信息，如以下信息：

contentType   "text/plain"originalContentType    "application/json;charset=UTF-8"{"message":"hello"}

我的pojo包含一个字段（字符串消息），所以我希望只有json字符串会被发送到kafka。
restcontroller中的方法test（）触发生产者：

@EnableBinding(ProducerChannels.class)
@SpringBootApplication
@RestController
public class KafkaStreamProducerApplication {

private MessageChannel consumer;

public KafkaStreamProducerApplication(ProducerChannels channels) {
    this.consumer = channels.consumer();
}

@PostMapping("/test/{message}")
public void test(@PathVariable String message) {
    Message<MyMessage> msg = MessageBuilder.withPayload(new MyMessage(message)).build();
    this.consumer.send(msg);
}

interface ProducerChannels {

    @Output
    MessageChannel consumer();
}

我的应用程序.properties

spring.cloud.stream.bindings.consumer.destination=consumer
spring.cloud.stream.bindings.consumer.content-type=application/json

如果您能推荐任何关于这个主题的文档或示例，我也将不胜感激。github上的例子通常都很简单，它们使用了很多自动配置，没有任何解释。我使用的例子是rabbitmq。