Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Current state: Under Discussion

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

JIRA: here [Change the link from KAFKA-1 to your own ticket]

...

If the field is omitted in the request body, the current behaviour of creating connectors will be preserved. An example request body would look like:

CreateConnectorRequest

{

    "name": "file-src-1",

    "config": {

        "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector",

        "file": "test.txt",

        "topic": "test-topic",

        "tasks.max": "1"

    },

    "initial_offset": [

    {

      "partition": {

        // Connector-defined source partition

      },

      "offset": {

        // Connector-defined source offset

      }

    }

  ]

}


This method will be supported in both the distributed mode as well as the standalone mode.

...