connector_offsets
Creates, updates, deletes, gets or lists a connector_offsets resource.
Overview
| Name | connector_offsets |
| Type | Resource |
| Id | confluent.connect.connector_offsets |
Fields
| Name | Datatype | Description |
|---|---|---|
id | string | The ID of the connector. |
name | string | The name of the connector. |
metadata | object | Metadata of the connector offset. |
offsets | array | Array of offsets which are categorised into partitions. |
Methods
| Name | Accessible by | Required Params | Description |
|---|---|---|---|
get_connectv1connector_offsets | SELECT | connector_name, environment_id, kafka_cluster_id |  Get the current offsets for the connector. The offsets provide information on the point in the source system, from which the connector is pulling in data. The offsets of a connector are continuously observed periodically and are queryable via this API. |
SELECT examples
SELECT
id,
name,
metadata,
offsets
FROM confluent.connect.connector_offsets
WHERE connector_name = '{{ connector_name }}'
AND environment_id = '{{ environment_id }}'
AND kafka_cluster_id = '{{ kafka_cluster_id }}';