如何在Pentaho 9.2中向Kafka传递消息Header？

1. 进入Kafka Producer配置界面 #

找到转换里的Kafka producer步骤，双击打开配置窗口。

2. 切换到「Headers」标签页 #

在配置界面顶部标签栏，点击「Headers」选项卡，这是配置消息头的专属区域。

3. 添加必填Header键值对 #

• 点击标签页内的「Add」按钮，新增一行Header配置项
• 在「Key」列填写错误提示里要求不能为空的参数名称
• 在「Value」列设置对应值：
  • 固定值直接输入字符串即可
  • 动态值可引用转换中的字段，输入${字段名}即可关联对应字段
• 确认所有必填Header都已添加完成

4. 验证配置效果 #

点击「OK」保存配置，运行转换，检查是否还会出现参数为空的错误提示。

补充提示 #

• 若需动态生成Header值，可在Kafka Producer步骤前添加「User Defined Java Expression」或「Calculator」步骤，提前计算好Header值并存入字段，再在Headers标签页引用该字段
• 要确认Header是否发送成功，可使用你提供的Kafka consumer步骤接收消息，在Consumer配置中开启Header解析，查看消息头是否包含配置的键值对

内容的提问来源于stack exchange，提问作者Сергей Степин