由于kafka本身不支持报头，因此kafka消息总线支持您所描述的确切机制—只是您必须选择要由总线传输的报头名称，以避免传输不需要的报头。
请参阅应用程序配置。
向下滚动到kafka消息总线属性。

messagebus:
 kafka:
  # connection properties
  brokers:                                localhost:9092  (1)
  zkAddress:                              localhost:2181  (2)
  socketBufferSize:                       2097152         (3)
  # operating mode
  mode:                                   embeddedHeaders (4)
  offsetManagement:                       kafkaTopic      
  headers:
  # comma-delimited list of additional header names to transport (6)
  ...

要由总线传输的自定义标头的列表。
编辑
对于rabbit，默认情况下传输所有标头：

replyHeaderPatterns:       STANDARD_REPLY_HEADERS,*   
    ...
    requestHeaderPatterns:     STANDARD_REQUEST_HEADERS,*

编辑
如果您的意思是希望使用相同的技术使用sink/source从kafka发送/接收数据，那么您可以使用xd的支持类来实现这一点-请参阅 EmbeddedHeadersMessageConverter . 头值被编码为json。