Skip to main content

GetKafka

概述​

Kafka 0.8版本的对接组件。

通过Apache Kafka 0.8.x版本的消费API来消费消息。与发送消息的Kafka组件 PutKafka 相对应。

GetKafka属性说明​

ZooKeeper连接串 ： 为了连接到ZooKeeper的连接字符串。由英文逗号分隔的列表，其基本格式为 <host>\:<port>。 比如 host1\:2181,host2\:2181,host3\:2188​
主题名 ： 生成消息的主题名。​

示例​

demo

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

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

#####GetKafka设置 ConsumeMQTT组件属于只定时驱动类型组件，不允许有上级流文件驱动。需要配置时间调度策略，一般使用Timer driver且设置0s调度时间间隔，相当于订阅客户端一直保持启动的状态。

get_timer

设置"ZooKeeper连接串"、"主题名"表示你想收到哪个主题的消息，也就是想订阅的主题。

get_properties.png

#####说明

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

流程模板​

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