Retrieve Data from Kafka

To automatically retrieve data from Kafka, create a new Fetch Task by following these steps. The connector runs each fetch task automatically, based on the schedule that is configured in the configuration file.

To create a new Fetch Task

  1. Stop the connector.
  2. Open the configuration file in a text editor.
  3. In the [FetchTasks] section of the configuration file, specify the number of fetch tasks using the Number parameter. If you are configuring the first fetch task, type Number=1. If one or more fetch tasks have already been configured, increase the value of the Number parameter by one (1). Below the Number parameter, specify the names of the fetch tasks, starting from zero (0). For example:

    [FetchTasks]
    Number=1
    0=MyTask
  4. Below the [FetchTasks] section, create a new TaskName section. The name of the section must match the name of the new fetch task. For example:

    [FetchTasks]
    Number=1
    0=MyTask
    
    [MyTask]
  1. In the new section, set the following parameters:

    Brokers A comma-separated list of Kafka brokers to retrieve data from.
    Topics The topics to retrieve data from.
    TopicsByPattern Determines the behavior of the Topics parameter. By default, you specify a comma-separated list of topic names. To process all topics that match a regular expression, set this parameter to TRUE and specify a regular expression instead.
    ConsumerOptionNameN A list of advanced consumer options that you want to set.
    ConsumerOptionValueN A list of values for the advanced consumer options.

    For example:

    [MyTask]
    Brokers=my-kafka-host:9092
    Topics=IDOL.*Events
    TopicsByPattern=TRUE
    ConsumerOptionName0=security.protocol
    ConsumerOptionValue0=ssl
    ...
  2. Save and close the configuration file. You can now start the connector.