分布式消息（Kafka）

连接参数

创建分布式（Kafka）连接时连接参数说明如表1所示。如果需要连接的Kafka配置了IP地址白名单限制，则需要放通集成工作台公网出口访问地址“124.70.83.64”。

消费消息

消费消息。

• 输入参数

  用户配置发送数据执行动作，相关参数说明如表2所示。

  表2 消费消息输入参数说明

  参数	必须	说明
  Topic	是	Topic。
  消费组	是	消费组的group.id。
  最大记录数	是	单次拉取得到的最大数据量。
  扩展配置	否	输入键名称和键值，有输入框模式和键值模式。
  轮询间隔	是	轮询间隔，单位为秒。

• 输出参数

  用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考表3。

  表3 消费消息输出参数说明

  参数	说明
  分区	分区。
  偏移量	偏移量。
  时间戳	时间戳。
  Key值	Key值。
  Value值	Value值。
  数据列表	数据列表。

Topic列表

返回Topic列表信息。

• 输入参数

  用户配置Topic列表执行动作，相关参数说明如表4所示。

  表4 Topic列表输入参数说明

  参数	必须	说明
  扩展配置	是	输入键名称和键值，键值模式。

• 输出参数

  用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考表5。

  表5 Topic列表输出参数说明

  参数	说明
  Topic列表	Topic列表信息。

发送数据

发送数据。

• 输入参数

  用户配置发送数据执行动作，相关参数说明如表6所示。

  表6 发送数据输入参数说明

  参数	必须	说明
  扩展配置	否	输入键名称和键值，键值模式。
  Topic	是	为Kafka服务器中的Topic名称。
  数据列表	是	选择数组类型的节点输出，可切换为数组模式。 数组放要传输的事件消息，以数组对象的方式进行传输。 示例： [ { "message": "content" } ...... ]

• 输出参数

  用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考表7。

  表7 发送数据输出参数说明

  参数	说明
  保存结果	返回发送数据的保存结果。

指定分区发送

发送数据给指定的分区

• 输入参数

  用户配置指定分区发送执行动作，相关参数说明如表8所示。

  表8 指定分区发送输入参数说明

  参数	必须	说明
  Topic	是	Topic。
  扩展配置	是	输入键名称和键值，键值模式。
  数据列表	是	选择数组类型的节点输出，可切换为数组模式填写value值、分区、Key值。

• 输出参数

  用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考表9。

  表9 指定分区发送输出参数说明

  参数	说明
  保存结果	返回指定分区发送的数据保存结果。