connector_offsets

Creates, updates, deletes, gets or lists a connector_offsets resource.

Overview

Name	connector_offsets
Type	Resource
Id	confluent.connect.connector_offsets

Fields

The following fields are returned by SELECT queries:

get_connectv1_connector_offsets

Connector Offsets.

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

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
get_connectv1_connector_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.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

Name	Datatype	Description
connector_name	string	The unique name of the connector.
environment_id	string	The unique identifier of the environment this resource belongs to.
kafka_cluster_id	string	The unique identifier for the Kafka cluster.

SELECT examples

get_connectv1_connector_offsets

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
id,
name,
metadata,
offsets
FROM confluent.connect.connector_offsets
WHERE connector_name = '{{ connector_name }}' -- required
AND environment_id = '{{ environment_id }}' -- required
AND kafka_cluster_id = '{{ kafka_cluster_id }}' -- required
;