任务是向 Kafka 主题发送具有具体价值的消息。
例如,我想以纯文本形式发送“someValue”。
为此我应该使用 PublishKafkaRecord_2_6 中的哪个 Kafka 属性?
例如,我将“FreeFormTextRecordSetWriter”视为一种服务,它将 RecordSet 的内容写入自由格式的文本。
但是在 PublishKafkaRecord_2_6 中我可以设置“someValue”以将其发布在目标主题中。
任务是向 Kafka 主题发送具有具体价值的消息。
例如,我想以纯文本形式发送“someValue”。
为此我应该使用 PublishKafkaRecord_2_6 中的哪个 Kafka 属性?
例如,我将“FreeFormTextRecordSetWriter”视为一种服务,它将 RecordSet 的内容写入自由格式的文本。
但是在 PublishKafkaRecord_2_6 中我可以设置“someValue”以将其发布在目标主题中。
你不会。Kafka 处理器只是为 Kafka 客户端详细信息和序列化设置了生产者。
您需要设置传入处理器,例如使用GenerateFlowFile