Updated on 2022-09-15 GMT+08:00

From Kafka

Sample JSON File

"from-config-values": {
           "configs": [
               {
                   "inputs": [
                       {
                       "name": "fromJobConfig.topicsList",
                       "value": "est1,est2"
                       },
                       {
                       "name": "fromJobConfig.kafkaConsumerStrategy",
                       "value": "EARLIEST"
                       },
                       {
                       "name": "fromJobConfig.isPermanency",
                       "value": "true"
                       }
                   ],
                   "name": "fromJobConfig"
               }
           ]
       }

Parameter Description

Parameter

Mandatory

Type

Description

fromJobConfig.topicsList

Yes

String

List of Kafka topics. Separate multiple topics by commas (,).

fromJobConfig.kafkaConsumerStrategy

Yes

Enumeration

Used to set the initial offset when data is pulled from Kafka. The options are as follows:

  • LATEST: maximum offset, that is, the latest data
  • EARLIEST: minimum offset, that is, the earliest data

fromJobConfig.isPermanency

Yes

Boolean

Whether to run permanently

fromJobConfig.groupId

No

String

Consumer group ID

If you export data from DMS Kafka, enter any value for Kafka Platinum but a valid consumer group ID for Kafka Basic.

fromJobConfig.dataFormat

Yes

Enumeration

Format used for parsing data. The options are as follows:

  • BINARY: Data is transferred without being parsed, which is applicable to file migration.
  • CSV: Source data will be migrated after being parsed in CSV format.

fromJobConfig.maxPollRecords

No

String

Maximum number of requests that can be sent to Kafka each time

fromJobConfig.maxPollInterval

No

String

Maximum interval between each poll

fromJobConfig.separator

No

String

Field delimiter