Versions Compared

Key

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

...

  1. Validate connector configs
  2. Validate the offset using the same checks performed while altering connector offsets (PATCH /$connector/offsets ) as specified in KIP-875 (We will skip validations which check if the connector exists or is in STOPPED state)
  3. Submit the connector config with STOPPED state to config topic.
  4. Update the Set the offset of the connector created in step 1 to the value of “initial_offsets”If “initial_state” property of the connector is
  5. set

    Write connector config (with whatever initial state is specified in the request,

    the runtime will set the state of the connector to that value. If “initial_state” is not specified, the runtime will set the state of the connector to RUNNING

    or the default if none is specified)

If Connect runtime encounters an error in any of these steps, it will cleanup (if required) and return an error response.

...