Apache Kafka ConnectorResetOffsets

Apache Kafka ConnectorResetOffsets
Certified
Reset a Kafka Connect connector's offsets

Deletes all of the connector's committed offsets, so it restarts from the beginning (source) or from the consumer group's default reset policy (sink) next time it runs.

The connector must be in the STOPPED state for this call to succeed; resetting offsets via DELETE /connectors/{name}/offsets is a [KIP-875](https://cwiki.apache.org/confluence/display/KAFKA/KIP-875: +First-class+offsets+support+in+Kafka+Connect) concept only available on Kafka Connect clusters running Kafka 3.6+. This task does not pre-validate the connector's state client-side — it always sends the request and surfaces Connect's error body verbatim (HTTP 400) if the connector isn't STOPPED. On older clusters that don't support this, delete and recreate the connector instead.

yaml
type: io.kestra.plugin.kafka.ConnectorResetOffsets

Examples

yaml
id: kafka_connector_reset_offsets
namespace: company.team

tasks:
  - id: reset_offsets
    type: io.kestra.plugin.kafka.ConnectorResetOffsets
    connectUrl: http://connect:8083
    connectorName: orders_jdbc_source

Properties

connectUrl *string

Kafka Connect REST API base URL

For example http://connect: 8083. Kafka Connect has no dedicated Java admin client — every operation goes through this REST API.

connectorName *string

Connector name

headers object

Additional HTTP headers

Sent on every request to the Connect REST API. Useful when the worker sits behind a reverse proxy or expects a bearer token, e.g. Authorization: Bearer ....

password string

Basic auth password

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

username string

Basic auth username

Required together with password when the Connect REST API is protected with HTTP basic auth. Leave both unset to call an unauthenticated worker — no Authorization header is sent in that case.

Outputs

connectorName string

Connector name

message string

Confirmation message returned by the Connect API