KafkaConnector
Usage example¶
Prerequisites
Apply the resource with:
Verify the newly created KafkaConnector
:
The output is similar to the following:
Name Service Name Project Connector Class State Tasks Total Tasks Running
my-kafka-connect my-kafka my-aiven-project io.aiven.kafka.connect.opensearch.OpensearchSinkConnector RUNNING <tasksStatus.total> <tasksStatus.running>
KafkaConnector¶
KafkaConnector is the Schema for the kafkaconnectors API.
Required
apiVersion
(string). Valueaiven.io/v1alpha1
.kind
(string). ValueKafkaConnector
.metadata
(object). Data that identifies the object, including aname
string and optionalnamespace
.spec
(object). KafkaConnectorSpec defines the desired state of KafkaConnector. See below for nested schema.
spec¶
Appears on KafkaConnector
.
KafkaConnectorSpec defines the desired state of KafkaConnector.
Required
connectorClass
(string, MaxLength: 1024). The Java class of the connector.project
(string, Immutable, Pattern:^[a-zA-Z0-9_-]+$
, MaxLength: 63). Identifies the project this resource belongs to.serviceName
(string, Immutable, Pattern:^[a-z][-a-z0-9]+$
, MaxLength: 63). Specifies the name of the service that this resource belongs to.userConfig
(object, AdditionalProperties: string). The connector-specific configuration To build config values from secret the template function{{ fromSecret "name" "key" }}
is provided when interpreting the keys. Where "name" is the name of the secret and "key" is the key in the secret in the same namespace as the KafkaConnector.
Optional
authSecretRef
(object). Authentication reference to Aiven token in a secret. See below for nested schema.
authSecretRef¶
Appears on spec
.
Authentication reference to Aiven token in a secret.
Required