如何在PublishKafkaRecord_2_6中配置发送指定文本消息到Kafka主题?
在PublishKafkaRecord_2_6中发送固定纯文本消息的配置方法
要发送固定纯文本内容(比如"someValue")到Kafka主题,核心是通过FreeFormTextRecordSetWriter定义消息内容,再关联到PublishKafkaRecord_2_6处理器,具体配置步骤如下:
创建并配置FreeFormTextRecordSetWriter实例
- 新建一个FreeFormTextRecordSetWriter控制器服务
- 在其属性中找到Free Form Text参数,直接填入你要发送的固定文本值,比如
someValue - 启用该控制器服务
配置PublishKafkaRecord_2_6处理器
- 在处理器的Record Writer属性中,选择刚才配置好的FreeFormTextRecordSetWriter实例
- 完成Kafka基础配置:填写Kafka Brokers、Topic Name等必填属性
- 若没有现成FlowFile作为输入,可搭配GenerateFlowFile处理器生成空FlowFile触发消息发送(FreeFormTextRecordSetWriter会忽略FlowFile内容,直接使用配置的固定文本)
注意:PublishKafkaRecord_2_6本身不直接设置消息内容,而是通过绑定的RecordSetWriter生成消息体,FreeFormTextRecordSetWriter的Free Form Text属性就是指定固定纯文本消息的关键配置项。
内容的提问来源于stack exchange,提问作者Jelly
相关产品推荐
相关产品推荐

