Skip to main content

PutKafka

概述​

Kafka 0.8版本的对接组件。

通过Apache Kafka 0.8.X版本的生成API来将输入数据流内容作为消息发送。要发送的消息可以是单独的数据流，也可以是分隔符分隔的（使用自定义分隔符，比如”换行“） 。与发送消息的Kafka组件 GetKafka 相对应。

PutKafka属性说明​

Kafka Brokers ： 由英文逗号分隔的Kafka Brokers列表，其基本格式为 <host>\:<port>​
主题名 ： 生成消息的主题名。​
客户端名 ：当与Kafka通信而使用的客户端名。​

示例​

demo

#####样本数据 例子中，我们准备1个kafka服务端，这些基本信息要知道，会在消息发布和订阅时使用。

连接的kafka服务器环境信息
kafka访问环境：172.18.89.103:9092
zookeeper：172.18.89.103:2181
topic：orchsym-demo-test

#####PutKafka设置 PutKafka组件配置Kafka Brokers ， 设置"主题名"表示发布消息的所属主题，客户端名可以自定义。

put_properties.png

#####说明

平台支持使用多客户端订阅同一消息

流程模板​

参见附件(请右键另存保存)：PutKafka_GetKafka消息发布订阅示例