| 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.ClusterLinkSpec) ClusterLinkSpec defines the desired state of the ClusterLink application resource. More info: https://docs.confluent.io/operator/current/co-link-clusters.html |
object (io.confluent.platform.api.v1beta1.ClusterLinkStatus) ClusterLinkStatus defines the observed state of the cluster link. |
apiVersion: platform.confluent.io/v1beta1 kind: ClusterLink metadata: name: clusterlink-example namespace: confluent spec: destinationKafkaCluster: kafkaRestClassRef: name: krc-example sourceKafkaCluster: bootstrapEndpoint: example.com:9092 clusterID: test_kafka_cluster_id consumerGroupFilters: - name: filter-example patternType: LITERAL filterType: INCLUDE aclFilters: - resourceFilter: resourceType: topic name: coffee patternType: prefixed accessFilter: principal: User:Bob host: example .com operation: read permissionType: allow configs: connections.max.idle.ms: "620000" | 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 | 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 | 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 | 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 | 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 | 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 | 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 | 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" | 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 | 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 | 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 | 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 | 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 | 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