Get Confluent | Sign up for Confluent Cloud or download Confluent Platform

Confluent for Kubernetes API Reference (2.3)

ConfluentRolebinding

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.ConfluentRolebindingSpec)

ConfluentRolebindingSpec defines the desired state of the rolebinding for the Confluent component when RBAC is enabled. More info: https://docs.confluent.io/operator/current/co-manage-rbac.html

object (io.confluent.platform.api.v1beta1.ConfluentRolebindingStatus)

ConfluentRolebindingStatus defines the observed state of the ConfluentRolebinding.

apiVersion: platform.confluent.io/v1beta1 kind: ConfluentRolebinding metadata: name: cfrb-example namespace: confluent spec: principal: type: user name: user-example clustersScopeByIds: schemaRegistryClusterId: id_schemaregistry_confluent role: SecurityAdmin kafkaRestClassRef: name: default

Connector

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.ConnectorSpec)

ConnectorSpec defines the desired state of the Connector application resource. More info: https://docs.confluent.io/operator/current/co-manage-connectors.html

object (io.confluent.platform.api.v1beta1.ConnectorStatus)

ConnectorStatus defines the observed state of the Connector application resource.

apiVersion: platform.confluent.io/v1beta1 kind: Connector metadata: name: connector-example namespace: confluent spec: class: "org.apache.kafka.connect.file.FileStreamSinkConnector" taskMax: 4 connectClusterRef: name: connect namespace: confluent connectRest: authentication: type: basic secretRef: basic-credential-example configs: topics: "test-topic" file: "/tmp/test.txt" restartPolicy: type: OnFailure maxRetry: 20

Connect

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.ConnectSpec)

ConnectSpec defines the desired state of the Connect cluster.

object (io.confluent.platform.api.v1beta1.ConnectStatus)

ConnectStatus defines the observed state of the Connect cluster.

apiVersion: platform.confluent.io/v1beta1 kind: Connect metadata: name: connect-example namespace: confluent spec: replicas: 2 image: application: confluentinc/cp-server-connect:7.0.1 init: confluentinc/confluent-init-container-operator:2.2.0-1 authentication: type: basic basic: secretRef: connect-basic-example tls: autoGeneratedCerts: true dependencies: kafka: bootstrapEndpoint: kafka.confluent.svc.cluster.local:9071 authentication: type: plain jaasConfig: secretRef: credential-example tls: enabled: true

ControlCenter

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.ControlCenterSpec)

ControlCenterSpec defines the desired state of the Control Center cluster.

object (io.confluent.platform.api.v1beta1.ControlCenterStatus)

ControlCenterStatus defines the observed state of the Control Center cluster.

apiVersion: platform.confluent.io/v1beta1 kind: ControlCenter metadata: name: controlcenter-example namespace: confluent spec: replicas: 1 image: application: confluentinc/cp-enterprise-control-center:7.0.1 init: confluentinc/confluent-init-container:2.2.0-1 dataVolumeCapacity: 10Gi tls: autoGeneratedCerts: true authentication: type: basic basic: secretRef: controlcenter-basic-example dependencies: kafka: bootstrapEndpoint: kafka.confluent.svc.cluster.local:9071 authentication: type: plain jaasConfig: secretRef: credential-example

KafkaRestClass

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.KafkaRestClassSpec)

KafkaRestClassSpec defines the client configurations to access Kafka Rest API. This resource is referenced by other CFK resources to access Kafka Rest APIs.

object (io.confluent.platform.api.v1beta1.KafkaRestClassStatus)

KafkaRestClassStatus defines the observed state of the KafkaRestClass.

apiVersion: platform.confluent.io/v1beta1 kind: KafkaRestClass metadata: name: krc-example namespace: confluent spec: kafkaClusterRef: name: kafka namespace: confluent kafkaRest: authentication: type: bearer bearer: secretRef: rest-credential-example

KafkaRestProxy

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.KafkaRestProxySpec)

KafkaRestProxySpec defines the desired state of the KafkaRestProxy cluster.

object (io.confluent.platform.api.v1beta1.KafkaRestProxyStatus)

KafkaRestProxyStatus defines the observed state of the KafkaRestProxy.

apiVersion: platform.confluent.io/v1beta1 kind: KafkaRestProxy metadata: name: krp-example namespace: confluent spec: image: application: confluentinc/cp-kafka-rest:7.0.1 init: confluentinc/confluent-init-container:2.2.0-1 replicas: 3 tls: autoGeneratedCerts: true dependencies: kafka: bootstrapEndpoint: kafka.confluent.svc.cluster.local:9071 authentication: type: plain jaasConfig: secretRef: credential-example tls: enabled: true

Kafka

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.KafkaSpec)

KafkaSpec defines the desired state of the Kafka cluster.

object (io.confluent.platform.api.v1beta1.KafkaStatus)

KafkaStatus defines the observed state of the Kafka cluster.

apiVersion: platform.confluent.io/v1beta1 kind: Kafka metadata: name: kafka-example namespace: confluent spec: replicas: 3 image: application: confluentinc/cp-server:7.0.1 init: confluentinc/confluent-init-container:2.2.0-1 dataVolumeCapacity: 10Gi tls: autoGeneratedCerts: true listeners: internal: authentication: type: plain jaasConfig: secretRef: credential-example tls: enabled: true dependencies: zookeeper: endpoint: zookeeper.confluent.svc.cluster.local:2181

KafkaTopic

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

object (io.confluent.platform.api.v1beta1.KafkaTopicSpec)

KafkaTopicSpec defines the desired state of the KafkaTopic application resource. More info: https://docs.confluent.io/operator/current/co-manage-topics.html

object (io.confluent.platform.api.v1beta1.KafkaTopicStatus)

KafkaTopicStatus defines the observed state of the KafkaTopic.

apiVersion: platform.confluent.io/v1beta1 kind: KafkaTopic metadata: name: topic-example namespace: confluent spec: replicas: 1 partitionCount: 12 kafkaClusterRef: name: kafka namespace: confluent configs: cleanup.policy: "compact"

KsqlDB

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.KsqlDBSpec)

KsqlDBSpec defines the desired state of the ksqlDB cluster.

object (io.confluent.platform.api.v1beta1.KsqlDBStatus)

KsqlDBStatus defines the observed state of the ksqlDB cluster.

apiVersion: platform.confluent.io/v1beta1 kind: KsqlDB metadata: name: ksqldb-example namespace: confluent spec: replicas: 2 image: application: confluentinc/cp-ksqldb-server:7.0.1 init: confluentinc/confluent-init-container:2.2.0-1 dataVolumeCapacity: 10Gi tls: autoGeneratedCerts: true authentication: type: basic basic: secretRef: ksqldb-basic-example dependencies: kafka: bootstrapEndpoint: kafka.confluent.svc.cluster.local:9071 authentication: type: plain jaasConfig: secretRef: credential-example tls: enabled: true

MigrationJob

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.MigrationJobSpec)

MigrationJobSpec defines the desired state of the MigrationJob.

object (io.confluent.platform.api.v1beta1.MigrationJobStatus)

MigrationJobStatus defines the observed state of the MigrationJob.

apiVersion: platform.confluent.io/v1beta1 kind: MigrationJob metadata: name: migration-example namespace: confluent annotations: platform.confluent.io/block-reconcile: "true" spec: initContainerImage: confluentinc/confluent-init-container:2.2.0-1 zookeeper: enabled: true name: zookeeper namespace: confluent release: zookeeper kafka: enabled: false name: kafka namespace: confluent release: kafka controlcenter: enabled: false name: controlcenter namespace: confluent release: controlcenter connect: enabled: false` name: connectors namespace: confluent release: connect ksqldb: enabled: false name: ksql namespace: confluent release: ksql replicator: enabled: false name: replicator namespace: confluent release: replicator schemaRegistry: enabled: false name: schemaregistry namespace: confluent release: schemaregistry

SchemaExporter

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

object (io.confluent.platform.api.v1beta1.SchemaExporterSpec)

SchemaExporterSpec specifies the desired state of the SchemaExporter application resource.

object (io.confluent.platform.api.v1beta1.SchemaExporterStatus)

SchemaExporterStatus defines the observed state of the schema exporter.

apiVersion: platform.confluent.io/v1beta1 kind: SchemaExporter metadata: name: schemaexporter-example namespace: confluent spec: sourceCluster: schemaRegistryClusterRef: name: schemaregistry namespace: source destinationCluster: schemaRegistryClusterRef: name: schemaregistry namespace: destination contextName: mycustom

SchemaRegistry

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.SchemaRegistrySpec)

SchemaRegistrySpec defines the desired state of the Schema Registry cluster.

object (io.confluent.platform.api.v1beta1.SchemaRegistryStatus)

SchemaRegistryStatus defines the observed state of the Schema Registry cluster.

apiVersion: platform.confluent.io/v1beta1 kind: SchemaRegistry metadata: name: schemaregistry-example namespace: confluent spec: replicas: 1 image: application: confluentinc/cp-schema-registry:7.0.1 init: confluentinc/confluent-init-container:2.2.0-1 tls: autoGeneratedCerts: true dependencies: kafka: bootstrapEndpoint: kafka.confluent.svc.cluster.local:9071 authentication: type: plain jaasConfig: secretRef: credential-example tls: enabled: true

Schema

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.SchemaSpec)

SchemaSpec specifies the desired state of the Schema application resource. More info: https://docs.confluent.io/operator/current/co-manage-schemas.html

object (io.confluent.platform.api.v1beta1.SchemaStatus)

SchemaStatus defines the observed state of the Schema.

apiVersion: v1 kind: ConfigMap metadata: name: schema-config namespace: confluent data: schema: | { "namespace": "io.confluent.examples.clients.basicavro", "type": "record", "name": "Payment", "fields": [ {"name": "id", "type": "string"} ] } --- apiVersion: platform.confluent.io/v1beta1 kind: Schema metadata: name: schema-example namespace: confluent spec: data: format: avro configRef: schema-config

Zookeeper

apiVersion
string

APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources

kind
string

Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds

required
object (io.confluent.platform.api.v1beta1.ZookeeperSpec)

ZookeeperSpec defines the desired state of the Zookeeper cluster.

object (io.confluent.platform.api.v1beta1.ZookeeperStatus)

ZookeeperStatus defines the observed state of the Zookeeper cluster.

apiVersion: platform.confluent.io/v1beta1 kind: Zookeeper metadata: name: zookeeper-example namespace: confluent spec: replicas: 3 image: application: confluentinc/cp-zookeeper:7.0.1 init: confluentinc/confluent-init-container:2.2.0-1 dataVolumeCapacity: 10Gi logVolumeCapacity: 10Gi