# 分布式消息（Kafka）
分布式消息（Kafka）连接器包含"Topic列表"、"发送数据"、"指定分区发送"三个执行动作和"消费消息"一个触发事件。
#### 连接参数
创建分布式（Kafka）连接时连接参数说明如[表1]所示。如果需要连接的Kafka配置了IP地址白名单限制，则需要放通集成工作台公网出口访问地址"124.70.83.64"。
 表1连接参数说明 
| 名称            | 必填 | 说明                          |
|:---|:---|:---|
| 连接名称          | 是  | 设置连接名称。                     |
| 描述            | 否  | 对于连接的信息描述说明。                |
| Kafka Broker  | 是  | Kafka Broker。               |
| JaaS账号        | 否  | JaaS账号。                     |
| JaaS密码        | 否  | JaaS密码。                     |
| SASL鉴权方式      | 否  | SASL鉴权方式。                   |
| 加密协议          | 否  | 加密协议。                       |
| Trust Store证书 | 否  | Trust Store证书，Base64编码后字符串。 |
| Trust Store密码 | 否  | Trust Store密码。              |
| Key Store证书   | 否  | Key Store证书，Base64编码后字符串。   |
| Key Store密码   | 否  | Key Store密码。                |
| Key密码         | 否  | Key密码。                      |
   
#### 消费消息
消费消息。
- 输入参数 用户配置发送数据执行动作，相关参数说明如[表2]所示。
   表2消费消息输入参数说明 
  | 参数    | 必须 | 说明                    |
  |:---|:---|:---|
  | Topic | 是  | Topic。                |
  | 消费组   | 是  | 消费组的group.id。         |
  | 最大记录数 | 是  | 单次拉取得到的最大数据量。         |
  | 扩展配置  | 否  | 输入键名称和键值，有输入框模式和键值模式。 |
  | 轮询间隔  | 是  | 轮询间隔，单位为秒。            |
     
  
- 输出参数 用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考[表3]。
   表3消费消息输出参数说明 
  | 参数     | 说明      |
  |:---|:---|
  | 分区     | 分区。     |
  | 偏移量    | 偏移量。    |
  | 时间戳    | 时间戳。    |
  | Key值   | Key值。   |
  | Value值 | Value值。 |
  | 数据列表   | 数据列表。   |
     
  
 
#### Topic列表
返回Topic列表信息。
- 输入参数 用户配置Topic列表执行动作，相关参数说明如[表4]所示。
   表4Topic列表输入参数说明 
  | 参数   | 必须 | 说明             |
  |:---|:---|:---|
  | 扩展配置 | 是  | 输入键名称和键值，键值模式。 |
     
  
- 输出参数 用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考[表5]。
   表5Topic列表输出参数说明 
  | 参数      | 说明         |
  |:---|:---|
  | Topic列表 | Topic列表信息。 |
     
  
 
#### 发送数据
发送数据。
- 输入参数 用户配置发送数据执行动作，相关参数说明如[表6]所示。
   表6发送数据输入参数说明 
  | 参数    | 必须 | 说明                                                                                                                                                                                          |
  |:---|:---|:---|
  | 扩展配置  | 否  | 输入键名称和键值，键值模式。                                                                                                                                                                              |
  | Topic | 是  | 为Kafka服务器中的Topic名称。                                                                                                                                                                         |
  | 数据列表  | 是  | 选择数组类型的节点输出，可切换为数组模式。 数组放要传输的事件消息，以数组对象的方式进行传输。 示例： ``` [ { "message": "content" } ...... ] ``` |
     
  
- 输出参数 用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考[表7]。
   表7发送数据输出参数说明 
  | 参数   | 说明           |
  |:---|:---|
  | 保存结果 | 返回发送数据的保存结果。 |
     
  
 
#### 指定分区发送
发送数据给指定的分区
- 输入参数 用户配置指定分区发送执行动作，相关参数说明如[表8]所示。
   表8指定分区发送输入参数说明 
  | 参数    | 必须 | 说明                                    |
  |:---|:---|:---|
  | Topic | 是  | Topic。                                |
  | 扩展配置  | 是  | 输入键名称和键值，键值模式。                        |
  | 数据列表  | 是  | 选择数组类型的节点输出，可切换为数组模式填写value值、分区、Key值。 |
     
  
- 输出参数 用户可以在之后的执行动作中调用该输出参数，输出参数说明请参考[表9]。
   表9指定分区发送输出参数说明 
  | 参数   | 说明               |
  |:---|:---|
  | 保存结果 | 返回指定分区发送的数据保存结果。 |