缺省情况下，你自己设定的Header会在传递的时候给清空，需要在配置中加上如下
spring.cloud.stream.kafka.binder.headers=header_name
如果有多个Header，用逗号隔开。
发送方：
MessageBuilder
.withPayload(message)
.setHeader("header_name","header_value")
.build()