connector_offsets_requests

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

Overview

Name	connector_offsets_requests
Type	Resource
Id	confluent.connect.connector_offsets_requests

Fields

Name	Datatype	Description
applied_at	string	The time at which the offsets were applied. The time is in UTC, ISO 8601 format.
previous_offsets	array	Array of offsets which are categorised into partitions.
request	object	The request made to alter offsets.
status	object	The response of the alter offsets operation.

Methods

Name	Accessible by	Required Params	Description
get_connectv1connector_offsets_request_status	SELECT	connector_name, environment_id, kafka_cluster_id	Get the status of the previous alter offset request.
alter_connectv1connector_offsets_request	EXEC	connector_name, environment_id, kafka_cluster_id, data__type	Request to alter the offsets of a connector. This supports the ability to PATCH/DELETE the offsets of a connector. Note, you will see momentary downtime as this will internally stop the connector, while the offsets are being altered. You can only make one alter offsets request at a time for a connector.

SELECT examples

Get the status of the previous alter offset request.

SELECT
applied_at,
previous_offsets,
request,
status
FROM confluent.connect.connector_offsets_requests
WHERE connector_name = '{{ connector_name }}'
AND environment_id = '{{ environment_id }}'
AND kafka_cluster_id = '{{ kafka_cluster_id }}';