Apache Kafka ConnectorGetOffsets
CertifiedGet a Kafka Connect connector's offsets
Apache Kafka ConnectorGetOffsets
Get a Kafka Connect connector's offsets
Returns the connector's committed offsets (source partitions/offsets for a source connector, consumer group offsets for a sink connector). The output offsets has the same shape expected by ConnectorAlterOffsets, so it can be piped directly between the two tasks.
type: io.kestra.plugin.kafka.ConnectorGetOffsetsExamples
Inspect a connector's offsets
id: kafka_connector_get_offsets
namespace: company.team
tasks:
- id: get_offsets
type: io.kestra.plugin.kafka.ConnectorGetOffsets
connectUrl: http://connect:8083
connectorName: orders_jdbc_sink
Properties
connectUrl *Requiredstring
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 *Requiredstring
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 Non-dynamicstring
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
offsets array
Per-partition offsets
Each entry has a partition map and an offset map; their exact keys depend on the connector type (source vs sink).
