# 源端为Kafka
#### JSON样例
```
"from-config-values": {
           "configs": [
               {
                   "inputs": [
                       {
                       "name": "fromJobConfig.topicsList",
                       "value": "est1,est2"
                       },
                       {
                       "name": "fromJobConfig.kafkaConsumerStrategy",
                       "value": "EARLIEST"
                       },
                       {
                       "name": "fromJobConfig.isPermanency",
                       "value": "true"
                       }
                   ],
                   "name": "fromJobConfig"
               }
           ]
       }
```
#### 参数说明
| 参数                                  | 是否必选 | 类型      | 说明                                                                                                                                                                                                                                                                 |
|:---|:---|:---|:---|
| fromJobConfig.topicsList            | 是    | String  | Kafka topic列表，可以为多个topic，以","作为分隔符。                                                                                                                                                                                                                                |
| fromJobConfig.kafkaConsumerStrategy | 是    | 枚举      | 从Kafka拉取数据时的初始偏移量设置： - LATEST：最大偏移量，即最新的数据。  - EARLIEST：最小偏移量，即最老的数据。   |
| fromJobConfig.isPermanency          | 是    | Boolean | 是否永久运行。                                                                                                                                                                                                                                                            |
| fromJobConfig.groupId               | 否    | String  | 用户指定消费组ID。 如果是从DMS Kafka导出数据，专享版请任意输入，标准版请输入有效的消费组ID。                                                                                                                                                                                |
| fromJobConfig.dataFormat            | 是    | 枚举      | 解析数据时使用的格式： - BINARY：适用于文件迁移场景，不解析数据内容原样传输。  - CSV：以CSV格式解析源数据。                |
| fromJobConfig.maxPollRecords        | 否    | String  | 每次向Kafka请求数据限制最大请求记录数。                                                                                                                                                                                                                                             |
| fromJobConfig.maxPollInterval       | 否    | String  | 每次poll之间的最大时间间隔。                                                                                                                                                                                                                                                   |
| fromJobConfig.separator             | 否    | String  | 字段分隔符。                                                                                                                                                                                                                                                             |