实例介绍
strimzi-kafka-operator:在Kubernetes上运行Apache Kafka®源码下载
Run Apache Kafka on Kubernetes and OpenShift
Strimzi提供了一种在Kubernetes或OpenShift上以各种部署配置运行Apache Kafka®集群的方式。
快速入门
要快速启动并运行,请查看我们针对Minikube、OKD(OpenShift Origin)和Kubernetes Kind的快速入门。
【实例截图】
【核心代码】
文件清单
└── strimzi-kafka-operator-ac92161118bf6b7975693f8f59925eba0aad2ea8
├── ADOPTERS.md
├── api
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── io
│ │ │ └── strimzi
│ │ │ ├── api
│ │ │ │ ├── kafka
│ │ │ │ │ ├── Crds.java
│ │ │ │ │ └── model
│ │ │ │ │ ├── bridge
│ │ │ │ │ │ ├── KafkaBridgeAdminClientSpec.java
│ │ │ │ │ │ ├── KafkaBridgeClientSpec.java
│ │ │ │ │ │ ├── KafkaBridgeConsumerSpec.java
│ │ │ │ │ │ ├── KafkaBridgeHttpConfig.java
│ │ │ │ │ │ ├── KafkaBridgeHttpCors.java
│ │ │ │ │ │ ├── KafkaBridge.java
│ │ │ │ │ │ ├── KafkaBridgeList.java
│ │ │ │ │ │ ├── KafkaBridgeProducerSpec.java
│ │ │ │ │ │ ├── KafkaBridgeResources.java
│ │ │ │ │ │ ├── KafkaBridgeSpec.java
│ │ │ │ │ │ ├── KafkaBridgeStatus.java
│ │ │ │ │ │ └── KafkaBridgeTemplate.java
│ │ │ │ │ ├── common
│ │ │ │ │ │ ├── authentication
│ │ │ │ │ │ │ ├── KafkaClientAuthentication.java
│ │ │ │ │ │ │ ├── KafkaClientAuthenticationOAuth.java
│ │ │ │ │ │ │ ├── KafkaClientAuthenticationPlain.java
│ │ │ │ │ │ │ ├── KafkaClientAuthenticationScram.java
│ │ │ │ │ │ │ ├── KafkaClientAuthenticationScramSha256.java
│ │ │ │ │ │ │ ├── KafkaClientAuthenticationScramSha512.java
│ │ │ │ │ │ │ └── KafkaClientAuthenticationTls.java
│ │ │ │ │ │ ├── CertAndKeySecretSource.java
│ │ │ │ │ │ ├── CertificateAuthority.java
│ │ │ │ │ │ ├── CertificateExpirationPolicy.java
│ │ │ │ │ │ ├── CertSecretSource.java
│ │ │ │ │ │ ├── ClientTls.java
│ │ │ │ │ │ ├── Condition.java
│ │ │ │ │ │ ├── ConnectorState.java
│ │ │ │ │ │ ├── Constants.java
│ │ │ │ │ │ ├── ContainerEnvVar.java
│ │ │ │ │ │ ├── CustomResourceConditions.java
│ │ │ │ │ │ ├── ExternalConfigurationReference.java
│ │ │ │ │ │ ├── ExternalLogging.java
│ │ │ │ │ │ ├── GenericSecretSource.java
│ │ │ │ │ │ ├── HasConfigurableLogging.java
│ │ │ │ │ │ ├── HasConfigurableMetrics.java
│ │ │ │ │ │ ├── HasLivenessProbe.java
│ │ │ │ │ │ ├── HasReadinessProbe.java
│ │ │ │ │ │ ├── HasStartupProbe.java
│ │ │ │ │ │ ├── InlineLogging.java
│ │ │ │ │ │ ├── jmx
│ │ │ │ │ │ │ ├── HasJmxOptions.java
│ │ │ │ │ │ │ ├── KafkaJmxAuthentication.java
│ │ │ │ │ │ │ ├── KafkaJmxAuthenticationPassword.java
│ │ │ │ │ │ │ └── KafkaJmxOptions.java
│ │ │ │ │ │ ├── JvmOptions.java
│ │ │ │ │ │ ├── Logging.java
│ │ │ │ │ │ ├── metrics
│ │ │ │ │ │ │ ├── JmxPrometheusExporterMetrics.java
│ │ │ │ │ │ │ └── MetricsConfig.java
│ │ │ │ │ │ ├── Password.java
│ │ │ │ │ │ ├── PasswordSecretSource.java
│ │ │ │ │ │ ├── PasswordSource.java
│ │ │ │ │ │ ├── Probe.java
│ │ │ │ │ │ ├── Rack.java
│ │ │ │ │ │ ├── Sidecar.java
│ │ │ │ │ │ ├── Spec.java
│ │ │ │ │ │ ├── SystemProperty.java
│ │ │ │ │ │ ├── template
│ │ │ │ │ │ │ ├── BuildConfigTemplate.java
│ │ │ │ │ │ │ ├── ContainerTemplate.java
│ │ │ │ │ │ │ ├── DeploymentStrategy.java
│ │ │ │ │ │ │ ├── DeploymentTemplate.java
│ │ │ │ │ │ │ ├── ExternalTrafficPolicy.java
│ │ │ │ │ │ │ ├── HasJmxSecretTemplate.java
│ │ │ │ │ │ │ ├── HasMetadataTemplate.java
│ │ │ │ │ │ │ ├── InternalServiceTemplate.java
│ │ │ │ │ │ │ ├── IpFamily.java
│ │ │ │ │ │ │ ├── IpFamilyPolicy.java
│ │ │ │ │ │ │ ├── JmxTransTemplate.java
│ │ │ │ │ │ │ ├── MetadataTemplate.java
│ │ │ │ │ │ │ ├── PodDisruptionBudgetTemplate.java
│ │ │ │ │ │ │ ├── PodManagementPolicy.java
│ │ │ │ │ │ │ ├── PodTemplate.java
│ │ │ │ │ │ │ ├── ResourceTemplate.java
│ │ │ │ │ │ │ └── StatefulSetTemplate.java
│ │ │ │ │ │ ├── TlsClientAuthentication.java
│ │ │ │ │ │ ├── tracing
│ │ │ │ │ │ │ ├── JaegerTracing.java
│ │ │ │ │ │ │ ├── OpenTelemetryTracing.java
│ │ │ │ │ │ │ └── Tracing.java
│ │ │ │ │ │ └── UnknownPropertyPreserving.java
│ │ │ │ │ ├── connect
│ │ │ │ │ │ ├── AbstractKafkaConnectSpec.java
│ │ │ │ │ │ ├── build
│ │ │ │ │ │ │ ├── Artifact.java
│ │ │ │ │ │ │ ├── Build.java
│ │ │ │ │ │ │ ├── DockerOutput.java
│ │ │ │ │ │ │ ├── DownloadableArtifact.java
│ │ │ │ │ │ │ ├── ImageStreamOutput.java
│ │ │ │ │ │ │ ├── JarArtifact.java
│ │ │ │ │ │ │ ├── MavenArtifact.java
│ │ │ │ │ │ │ ├── OtherArtifact.java
│ │ │ │ │ │ │ ├── Output.java
│ │ │ │ │ │ │ ├── Plugin.java
│ │ │ │ │ │ │ ├── TgzArtifact.java
│ │ │ │ │ │ │ └── ZipArtifact.java
│ │ │ │ │ │ ├── ConnectorPlugin.java
│ │ │ │ │ │ ├── ExternalConfigurationEnv.java
│ │ │ │ │ │ ├── ExternalConfigurationEnvVarSource.java
│ │ │ │ │ │ ├── ExternalConfiguration.java
│ │ │ │ │ │ ├── ExternalConfigurationVolumeSource.java
│ │ │ │ │ │ ├── KafkaConnect.java
│ │ │ │ │ │ ├── KafkaConnectList.java
│ │ │ │ │ │ ├── KafkaConnectResources.java
│ │ │ │ │ │ ├── KafkaConnectSpec.java
│ │ │ │ │ │ ├── KafkaConnectStatus.java
│ │ │ │ │ │ └── KafkaConnectTemplate.java
│ │ │ │ │ ├── connector
│ │ │ │ │ │ ├── AbstractConnectorSpec.java
│ │ │ │ │ │ ├── AutoRestart.java
│ │ │ │ │ │ ├── AutoRestartStatus.java
│ │ │ │ │ │ ├── KafkaConnector.java
│ │ │ │ │ │ ├── KafkaConnectorList.java
│ │ │ │ │ │ ├── KafkaConnectorSpec.java
│ │ │ │ │ │ └── KafkaConnectorStatus.java
│ │ │ │ │ ├── jmxtrans
│ │ │ │ │ │ ├── JmxTransOutputDefinitionTemplate.java
│ │ │ │ │ │ ├── JmxTransQueryTemplate.java
│ │ │ │ │ │ ├── JmxTransResources.java
│ │ │ │ │ │ └── JmxTransSpec.java
│ │ │ │ │ ├── kafka
│ │ │ │ │ │ ├── cruisecontrol
│ │ │ │ │ │ │ ├── BrokerCapacity.java
│ │ │ │ │ │ │ ├── BrokerCapacityOverride.java
│ │ │ │ │ │ │ ├── CruiseControlResources.java
│ │ │ │ │ │ │ ├── CruiseControlSpec.java
│ │ │ │ │ │ │ └── CruiseControlTemplate.java
│ │ │ │ │ │ ├── entityoperator
│ │ │ │ │ │ │ ├── EntityOperatorSpec.java
│ │ │ │ │ │ │ ├── EntityOperatorTemplate.java
│ │ │ │ │ │ │ ├── EntityTopicOperatorSpec.java
│ │ │ │ │ │ │ ├── EntityUserOperatorSpec.java
│ │ │ │ │ │ │ ├── TlsSidecar.java
│ │ │ │ │ │ │ └── TlsSidecarLogLevel.java
│ │ │ │ │ │ ├── EphemeralStorage.java
│ │ │ │ │ │ ├── exporter
│ │ │ │ │ │ │ ├── KafkaExporterResources.java
│ │ │ │ │ │ │ ├── KafkaExporterSpec.java
│ │ │ │ │ │ │ └── KafkaExporterTemplate.java
│ │ │ │ │ │ ├── JbodStorage.java
│ │ │ │ │ │ ├── KafkaAuthorizationCustom.java
│ │ │ │ │ │ ├── KafkaAuthorization.java
│ │ │ │ │ │ ├── KafkaAuthorizationKeycloak.java
│ │ │ │ │ │ ├── KafkaAuthorizationOpa.java
│ │ │ │ │ │ ├── KafkaAuthorizationSimple.java
│ │ │ │ │ │ ├── KafkaClusterSpec.java
│ │ │ │ │ │ ├── KafkaClusterTemplate.java
│ │ │ │ │ │ ├── Kafka.java
│ │ │ │ │ │ ├── KafkaList.java
│ │ │ │ │ │ ├── KafkaResources.java
│ │ │ │ │ │ ├── KafkaSpec.java
│ │ │ │ │ │ ├── KafkaStatus.java
│ │ │ │ │ │ ├── listener
│ │ │ │ │ │ │ ├── GenericKafkaListenerConfigurationBootstrap.java
│ │ │ │ │ │ │ ├── GenericKafkaListenerConfigurationBroker.java
│ │ │ │ │ │ │ ├── GenericKafkaListenerConfiguration.java
│ │ │ │ │ │ │ ├── GenericKafkaListener.java
│ │ │ │ │ │ │ ├── KafkaListenerAuthenticationCustom.java
│ │ │ │ │ │ │ ├── KafkaListenerAuthentication.java
│ │ │ │ │ │ │ ├── KafkaListenerAuthenticationOAuth.java
│ │ │ │ │ │ │ ├── KafkaListenerAuthenticationScramSha512.java
│ │ │ │ │ │ │ ├── KafkaListenerAuthenticationTls.java
│ │ │ │ │ │ │ ├── KafkaListenerType.java
│ │ │ │ │ │ │ ├── ListenerAddress.java
│ │ │ │ │ │ │ ├── ListenerStatus.java
│ │ │ │ │ │ │ └── NodeAddressType.java
│ │ │ │ │ │ ├── PersistentClaimStorage.java
│ │ │ │ │ │ ├── PersistentClaimStorageOverride.java
│ │ │ │ │ │ ├── SingleVolumeStorage.java
│ │ │ │ │ │ ├── Status.java
│ │ │ │ │ │ ├── Storage.java
│ │ │ │ │ │ └── UsedNodePoolStatus.java
│ │ │ │ │ ├── mirrormaker
│ │ │ │ │ │ ├── KafkaMirrorMakerClientSpec.java
│ │ │ │ │ │ ├── KafkaMirrorMakerConsumerSpec.java
│ │ │ │ │ │ ├── KafkaMirrorMaker.java
│ │ │ │ │ │ ├── KafkaMirrorMakerList.java
│ │ │ │ │ │ ├── KafkaMirrorMakerProducerSpec.java
│ │ │ │ │ │ ├── KafkaMirrorMakerResources.java
│ │ │ │ │ │ ├── KafkaMirrorMakerSpec.java
│ │ │ │ │ │ ├── KafkaMirrorMakerStatus.java
│ │ │ │ │ │ └── KafkaMirrorMakerTemplate.java
│ │ │ │ │ ├── mirrormaker2
│ │ │ │ │ │ ├── KafkaMirrorMaker2ClusterSpec.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2ConnectorSpec.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2List.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2MirrorSpec.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2Resources.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2Spec.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2Status.java
│ │ │ │ │ │ └── KafkaMirrorMaker2Template.java
│ │ │ │ │ ├── nodepool
│ │ │ │ │ │ ├── KafkaNodePool.java
│ │ │ │ │ │ ├── KafkaNodePoolList.java
│ │ │ │ │ │ ├── KafkaNodePoolSpec.java
│ │ │ │ │ │ ├── KafkaNodePoolStatus.java
│ │ │ │ │ │ ├── KafkaNodePoolTemplate.java
│ │ │ │ │ │ └── ProcessRoles.java
│ │ │ │ │ ├── podset
│ │ │ │ │ │ ├── StrimziPodSet.java
│ │ │ │ │ │ ├── StrimziPodSetList.java
│ │ │ │ │ │ ├── StrimziPodSetSpec.java
│ │ │ │ │ │ └── StrimziPodSetStatus.java
│ │ │ │ │ ├── rebalance
│ │ │ │ │ │ ├── KafkaRebalanceAnnotation.java
│ │ │ │ │ │ ├── KafkaRebalance.java
│ │ │ │ │ │ ├── KafkaRebalanceList.java
│ │ │ │ │ │ ├── KafkaRebalanceMode.java
│ │ │ │ │ │ ├── KafkaRebalanceSpec.java
│ │ │ │ │ │ ├── KafkaRebalanceState.java
│ │ │ │ │ │ └── KafkaRebalanceStatus.java
│ │ │ │ │ ├── topic
│ │ │ │ │ │ ├── KafkaTopic.java
│ │ │ │ │ │ ├── KafkaTopicList.java
│ │ │ │ │ │ ├── KafkaTopicSpec.java
│ │ │ │ │ │ └── KafkaTopicStatus.java
│ │ │ │ │ ├── user
│ │ │ │ │ │ ├── acl
│ │ │ │ │ │ │ ├── AclOperation.java
│ │ │ │ │ │ │ ├── AclResourcePatternType.java
│ │ │ │ │ │ │ ├── AclRuleClusterResource.java
│ │ │ │ │ │ │ ├── AclRuleGroupResource.java
│ │ │ │ │ │ │ ├── AclRule.java
│ │ │ │ │ │ │ ├── AclRuleResource.java
│ │ │ │ │ │ │ ├── AclRuleTopicResource.java
│ │ │ │ │ │ │ ├── AclRuleTransactionalIdResource.java
│ │ │ │ │ │ │ └── AclRuleType.java
│ │ │ │ │ │ ├── KafkaUserAuthentication.java
│ │ │ │ │ │ ├── KafkaUserAuthorization.java
│ │ │ │ │ │ ├── KafkaUserAuthorizationSimple.java
│ │ │ │ │ │ ├── KafkaUser.java
│ │ │ │ │ │ ├── KafkaUserList.java
│ │ │ │ │ │ ├── KafkaUserQuotas.java
│ │ │ │ │ │ ├── KafkaUserScramSha512ClientAuthentication.java
│ │ │ │ │ │ ├── KafkaUserSpec.java
│ │ │ │ │ │ ├── KafkaUserStatus.java
│ │ │ │ │ │ ├── KafkaUserTemplate.java
│ │ │ │ │ │ ├── KafkaUserTlsClientAuthentication.java
│ │ │ │ │ │ └── KafkaUserTlsExternalClientAuthentication.java
│ │ │ │ │ └── zookeeper
│ │ │ │ │ ├── ZookeeperClusterSpec.java
│ │ │ │ │ └── ZookeeperClusterTemplate.java
│ │ │ │ ├── ResourceAnnotations.java
│ │ │ │ └── ResourceLabels.java
│ │ │ ├── platform
│ │ │ │ ├── KubernetesVersion.java
│ │ │ │ ├── package-info.java
│ │ │ │ └── PlatformFeatures.java
│ │ │ └── plugin
│ │ │ └── security
│ │ │ └── profiles
│ │ │ ├── ContainerSecurityProviderContext.java
│ │ │ ├── impl
│ │ │ │ ├── BaselinePodSecurityProvider.java
│ │ │ │ ├── package-info.java
│ │ │ │ └── RestrictedPodSecurityProvider.java
│ │ │ ├── package-info.java
│ │ │ ├── PodSecurityProviderContext.java
│ │ │ └── PodSecurityProvider.java
│ │ └── resources
│ │ └── META-INF
│ │ └── services
│ │ └── io.strimzi.plugin.security.profiles.PodSecurityProvider
│ └── test
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ ├── api
│ │ │ └── kafka
│ │ │ └── model
│ │ │ ├── AbstractCrdIT.java
│ │ │ ├── AbstractCrdTest.java
│ │ │ ├── bridge
│ │ │ │ ├── KafkaBridgeCrdIT.java
│ │ │ │ └── KafkaBridgeTest.java
│ │ │ ├── connect
│ │ │ │ ├── KafkaConnectCrdIT.java
│ │ │ │ └── KafkaConnectTest.java
│ │ │ ├── connector
│ │ │ │ ├── KafkaConnectorCrdIT.java
│ │ │ │ └── KafkaConnectorTest.java
│ │ │ ├── CustomResourceConditionsTest.java
│ │ │ ├── ExamplesTest.java
│ │ │ ├── JvmOptionsTest.java
│ │ │ ├── kafka
│ │ │ │ ├── KafkaCrdIT.java
│ │ │ │ └── KafkaTest.java
│ │ │ ├── KafkaJmxOptionsTest.java
│ │ │ ├── mirrormaker
│ │ │ │ ├── KafkaMirrorMakerCrdIT.java
│ │ │ │ └── KafkaMirrorMakerTest.java
│ │ │ ├── mirrormaker2
│ │ │ │ ├── KafkaMirrorMaker2CrdIT.java
│ │ │ │ └── KafkaMirrorMaker2Test.java
│ │ │ ├── nodepool
│ │ │ │ ├── KafkaNodePoolCrdIT.java
│ │ │ │ └── KafkaNodePoolTest.java
│ │ │ ├── podset
│ │ │ │ ├── StrimziPodSetCrdIT.java
│ │ │ │ └── StrimziPodSetTest.java
│ │ │ ├── rebalance
│ │ │ │ ├── KafkaRebalanceCrdIT.java
│ │ │ │ └── KafkaRebalanceTest.java
│ │ │ ├── StructuralCrdIT.java
│ │ │ ├── topic
│ │ │ │ ├── KafkaTopicCrdIT.java
│ │ │ │ └── KafkaTopicTest.java
│ │ │ └── user
│ │ │ ├── KafkaUserCrdIT.java
│ │ │ └── KafkaUserTest.java
│ │ ├── platform
│ │ │ └── KubernetesVersionTest.java
│ │ └── test
│ │ └── CronTest.java
│ └── resources
│ ├── io
│ │ └── strimzi
│ │ └── api
│ │ └── kafka
│ │ └── model
│ │ ├── bridge
│ │ │ ├── KafkaBridge-minimal.yaml
│ │ │ ├── KafkaBridge.out.yaml
│ │ │ ├── KafkaBridge-with-extra-property.yaml
│ │ │ ├── KafkaBridge-with-metrics.yaml
│ │ │ ├── KafkaBridge-with-missing-required-property.yaml
│ │ │ ├── KafkaBridge-with-missing-tracing-type.yaml
│ │ │ ├── KafkaBridge-with-opentelemetry-tracing.yaml
│ │ │ ├── KafkaBridge-with-scram-sha-512-auth.yaml
│ │ │ ├── KafkaBridge-with-template.yaml
│ │ │ ├── KafkaBridge-with-tls-auth-with-missing-required.yaml
│ │ │ ├── KafkaBridge-with-tls-auth.yaml
│ │ │ ├── KafkaBridge-with-tls.yaml
│ │ │ ├── KafkaBridge-with-wrong-tracing-type.yaml
│ │ │ └── KafkaBridge.yaml
│ │ ├── connect
│ │ │ ├── KafkaConnect-minimal.yaml
│ │ │ ├── KafkaConnect.out.yaml
│ │ │ ├── KafkaConnect-with-external-configuration.yaml
│ │ │ ├── KafkaConnect-with-extra-property.yaml
│ │ │ ├── KafkaConnect-with-invalid-external-configuration.yaml
│ │ │ ├── KafkaConnect-with-invalid-replicas.yaml
│ │ │ ├── KafkaConnect-with-missing-required-property.yaml
│ │ │ ├── KafkaConnect-with-scram-sha-512-auth.yaml
│ │ │ ├── KafkaConnect-with-template.yaml
│ │ │ ├── KafkaConnect-with-tls-auth-with-missing-required.yaml
│ │ │ ├── KafkaConnect-with-tls-auth.yaml
│ │ │ ├── KafkaConnect-with-tls.yaml
│ │ │ └── KafkaConnect.yaml
│ │ ├── connector
│ │ │ ├── KafkaConnector.out.yaml
│ │ │ ├── KafkaConnector-with-filestream-sink.yaml
│ │ │ ├── KafkaConnector-with-filestream-source.yaml
│ │ │ └── KafkaConnector.yaml
│ │ ├── kafka
│ │ │ ├── Kafka-ca-ints.yaml
│ │ │ ├── Kafka-listener-name-and-status.yaml
│ │ │ ├── Kafka-minimal.yaml
│ │ │ ├── Kafka-new-listener-serialization.yaml
│ │ │ ├── Kafka-old-listener-serialization.yaml
│ │ │ ├── Kafka.out.yaml
│ │ │ ├── Kafka-with-entity-operator.yaml
│ │ │ ├── Kafka-with-extra-property.yaml
│ │ │ ├── Kafka-with-invalid-jmx-authentication.yaml
│ │ │ ├── Kafka-with-invalid-resource-memory.yaml
│ │ │ ├── Kafka-with-invalid-storage.yaml
│ │ │ ├── Kafka-with-invalid-zookeeper-jmx-authentication.yaml
│ │ │ ├── Kafka-with-jbod-storage-on-zookeeper.yaml
│ │ │ ├── Kafka-with-jbod-storage.yaml
│ │ │ ├── Kafka-with-maintenance.yaml
│ │ │ ├── Kafka-with-missing-required-property.yaml
│ │ │ ├── Kafka-with-null-maintenance.yaml
│ │ │ ├── Kafka-with-template.yaml
│ │ │ └── Kafka.yaml
│ │ ├── mirrormaker
│ │ │ ├── KafkaMirrorMaker-minimal.yaml
│ │ │ ├── KafkaMirrorMaker.out.yaml
│ │ │ ├── KafkaMirrorMaker-with-commit-and-abort.yaml
│ │ │ ├── KafkaMirrorMaker-with-extra-property.yaml
│ │ │ ├── KafkaMirrorMaker-with-missing-required-property.yaml
│ │ │ ├── KafkaMirrorMaker-with-scram-sha-512-auth.yaml
│ │ │ ├── KafkaMirrorMaker-with-template.yaml
│ │ │ ├── KafkaMirrorMaker-with-tls-auth-with-missing-required.yaml
│ │ │ ├── KafkaMirrorMaker-with-tls-auth.yaml
│ │ │ ├── KafkaMirrorMaker-with-tls.yaml
│ │ │ └── KafkaMirrorMaker.yaml
│ │ ├── mirrormaker2
│ │ │ ├── KafkaMirrorMaker2-minimal.yaml
│ │ │ ├── KafkaMirrorMaker2.out.yaml
│ │ │ ├── KafkaMirrorMaker2-with-external-configuration.yaml
│ │ │ ├── KafkaMirrorMaker2-with-extra-property.yaml
│ │ │ ├── KafkaMirrorMaker2-with-invalid-external-configuration.yaml
│ │ │ ├── KafkaMirrorMaker2-with-invalid-replicas.yaml
│ │ │ ├── KafkaMirrorMaker2-with-missing-required-property.yaml
│ │ │ ├── KafkaMirrorMaker2-with-scram-sha-512-auth.yaml
│ │ │ ├── KafkaMirrorMaker2-with-template.yaml
│ │ │ ├── KafkaMirrorMaker2-with-tls-auth-with-missing-required.yaml
│ │ │ ├── KafkaMirrorMaker2-with-tls-auth.yaml
│ │ │ ├── KafkaMirrorMaker2-with-tls.yaml
│ │ │ └── KafkaMirrorMaker2.yaml
│ │ ├── nodepool
│ │ │ ├── KafkaNodePool.out.yaml
│ │ │ ├── KafkaNodePool-with-invalid-role.yaml
│ │ │ └── KafkaNodePool.yaml
│ │ ├── podset
│ │ │ ├── StrimziPodSet.out.yaml
│ │ │ ├── StrimziPodSet-with-missing-required-property.yaml
│ │ │ └── StrimziPodSet.yaml
│ │ ├── rebalance
│ │ │ ├── KafkaRebalance-add-brokers.yaml
│ │ │ ├── KafkaRebalance-excluded-topics.yaml
│ │ │ ├── KafkaRebalance-minimal.yaml
│ │ │ ├── KafkaRebalance.out.yaml
│ │ │ ├── KafkaRebalance-performance-tuning.yaml
│ │ │ ├── KafkaRebalance-remove-brokers.yaml
│ │ │ ├── KafkaRebalance-with-goals-skip-hard-goal-check.yaml
│ │ │ ├── KafkaRebalance-with-goals.yaml
│ │ │ ├── KafkaRebalance-wrong-mode.yaml
│ │ │ └── KafkaRebalance.yaml
│ │ ├── topic
│ │ │ ├── KafkaTopic-minimal.yaml
│ │ │ ├── KafkaTopic.out.yaml
│ │ │ ├── KafkaTopicV1alpha1.yaml
│ │ │ ├── KafkaTopicV1beta1.yaml
│ │ │ ├── KafkaTopic-with-extra-property.yaml
│ │ │ └── KafkaTopic.yaml
│ │ └── user
│ │ ├── KafkaUser-minimal.yaml
│ │ ├── KafkaUser.out.yaml
│ │ ├── KafkaUserV1alpha1.yaml
│ │ ├── KafkaUserV1beta1.yaml
│ │ ├── KafkaUser-with-extra-property.yaml
│ │ └── KafkaUser.yaml
│ └── log4j2.properties
├── bridge.version
├── certificate-manager
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── io
│ │ │ └── strimzi
│ │ │ └── certs
│ │ │ ├── CertAndKey.java
│ │ │ ├── CertManager.java
│ │ │ ├── IpAndDnsValidation.java
│ │ │ ├── OpenSslCertManager.java
│ │ │ └── Subject.java
│ │ └── resources
│ │ └── openssl.conf
│ └── test
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ └── certs
│ │ ├── IpAndDnsValidationTest.java
│ │ ├── OpenSslCertManagerIT.java
│ │ └── SubjectTest.java
│ └── resources
│ └── log4j2.properties
├── CHANGELOG.md
├── cluster-operator
│ ├── Makefile
│ ├── pom.xml
│ ├── scripts
│ │ └── cluster_operator_run.sh
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── io
│ │ │ └── strimzi
│ │ │ └── operator
│ │ │ └── cluster
│ │ │ ├── ClusterOperatorConfig.java
│ │ │ ├── ClusterOperator.java
│ │ │ ├── FeatureGates.java
│ │ │ ├── leaderelection
│ │ │ │ ├── LeaderElectionManagerConfig.java
│ │ │ │ └── LeaderElectionManager.java
│ │ │ ├── Main.java
│ │ │ ├── model
│ │ │ │ ├── AbstractConfiguration.java
│ │ │ │ ├── AbstractModel.java
│ │ │ │ ├── AuthenticationUtils.java
│ │ │ │ ├── CertUtils.java
│ │ │ │ ├── ClusterCa.java
│ │ │ │ ├── ConfigMapUtils.java
│ │ │ │ ├── ContainerUtils.java
│ │ │ │ ├── cruisecontrol
│ │ │ │ │ ├── BrokerCapacity.java
│ │ │ │ │ ├── Capacity.java
│ │ │ │ │ ├── CpuCapacity.java
│ │ │ │ │ ├── CruiseControlMetricsReporter.java
│ │ │ │ │ └── DiskCapacity.java
│ │ │ │ ├── CruiseControlConfiguration.java
│ │ │ │ ├── CruiseControl.java
│ │ │ │ ├── DefaultSharedEnvironmentProvider.java
│ │ │ │ ├── DnsNameGenerator.java
│ │ │ │ ├── EntityOperator.java
│ │ │ │ ├── EntityTopicOperator.java
│ │ │ │ ├── EntityUserOperator.java
│ │ │ │ ├── ImagePullPolicy.java
│ │ │ │ ├── jmx
│ │ │ │ │ ├── JmxModel.java
│ │ │ │ │ └── SupportsJmx.java
│ │ │ │ ├── JvmOptionUtils.java
│ │ │ │ ├── KafkaBridgeAdminClientConfiguration.java
│ │ │ │ ├── KafkaBridgeCluster.java
│ │ │ │ ├── KafkaBridgeConsumerConfiguration.java
│ │ │ │ ├── KafkaBridgeProducerConfiguration.java
│ │ │ │ ├── KafkaBrokerConfigurationBuilder.java
│ │ │ │ ├── KafkaCluster.java
│ │ │ │ ├── KafkaConfiguration.java
│ │ │ │ ├── KafkaConnectBuild.java
│ │ │ │ ├── KafkaConnectBuildUtils.java
│ │ │ │ ├── KafkaConnectCluster.java
│ │ │ │ ├── KafkaConnectConfiguration.java
│ │ │ │ ├── KafkaConnectDockerfile.java
│ │ │ │ ├── KafkaConnectorConfiguration.java
│ │ │ │ ├── KafkaExporter.java
│ │ │ │ ├── KafkaListenerCustomAuthConfiguration.java
│ │ │ │ ├── KafkaMirrorMaker2Cluster.java
│ │ │ │ ├── KafkaMirrorMaker2Configuration.java
│ │ │ │ ├── KafkaMirrorMaker2Connectors.java
│ │ │ │ ├── KafkaMirrorMakerCluster.java
│ │ │ │ ├── KafkaMirrorMakerConsumerConfiguration.java
│ │ │ │ ├── KafkaMirrorMakerProducerConfiguration.java
│ │ │ │ ├── KafkaPool.java
│ │ │ │ ├── KafkaSpecChecker.java
│ │ │ │ ├── KafkaUpgradeException.java
│ │ │ │ ├── KafkaVersionChange.java
│ │ │ │ ├── KafkaVersion.java
│ │ │ │ ├── KRaftUtils.java
│ │ │ │ ├── ListenersUtils.java
│ │ │ │ ├── ListenersValidator.java
│ │ │ │ ├── logging
│ │ │ │ │ ├── LoggingModel.java
│ │ │ │ │ ├── LoggingUtils.java
│ │ │ │ │ └── SupportsLogging.java
│ │ │ │ ├── metrics
│ │ │ │ │ ├── MetricsModel.java
│ │ │ │ │ └── SupportsMetrics.java
│ │ │ │ ├── MetricsAndLogging.java
│ │ │ │ ├── ModelUtils.java
│ │ │ │ ├── NetworkPolicyUtils.java
│ │ │ │ ├── nodepools
│ │ │ │ │ ├── NodeIdAssignment.java
│ │ │ │ │ ├── NodeIdAssignor.java
│ │ │ │ │ ├── NodeIdRange.java
│ │ │ │ │ ├── NodePoolUtils.java
│ │ │ │ │ └── VirtualNodePoolConverter.java
│ │ │ │ ├── NodeRef.java
│ │ │ │ ├── NoImageException.java
│ │ │ │ ├── NoSuchResourceException.java
│ │ │ │ ├── PersistentVolumeClaimUtils.java
│ │ │ │ ├── PodDisruptionBudgetUtils.java
│ │ │ │ ├── PodRevision.java
│ │ │ │ ├── PodSetUtils.java
│ │ │ │ ├── ProbeUtils.java
│ │ │ │ ├── Quantities.java
│ │ │ │ ├── RbacUtils.java
│ │ │ │ ├── RestartReason.java
│ │ │ │ ├── RestartReasons.java
│ │ │ │ ├── securityprofiles
│ │ │ │ │ ├── ContainerSecurityProviderContextImpl.java
│ │ │ │ │ ├── PodSecurityProviderContextImpl.java
│ │ │ │ │ └── PodSecurityProviderFactory.java
│ │ │ │ ├── ServiceAccountUtils.java
│ │ │ │ ├── ServiceUtils.java
│ │ │ │ ├── SharedEnvironmentProvider.java
│ │ │ │ ├── StorageDiff.java
│ │ │ │ ├── StorageUtils.java
│ │ │ │ ├── TemplateUtils.java
│ │ │ │ ├── UnsupportedVersionException.java
│ │ │ │ ├── VolumeUtils.java
│ │ │ │ ├── WorkloadUtils.java
│ │ │ │ ├── ZookeeperCluster.java
│ │ │ │ ├── ZookeeperConfiguration.java
│ │ │ │ └── ZooKeeperSpecChecker.java
│ │ │ ├── operator
│ │ │ │ ├── assembly
│ │ │ │ │ ├── AbstractAssemblyOperator.java
│ │ │ │ │ ├── AbstractConnectOperator.java
│ │ │ │ │ ├── AbstractOperator.java
│ │ │ │ │ ├── BrokersInUseCheck.java
│ │ │ │ │ ├── CaReconciler.java
│ │ │ │ │ ├── ConnectBuildOperator.java
│ │ │ │ │ ├── ConnectOperatorMetricsHolder.java
│ │ │ │ │ ├── CruiseControlReconciler.java
│ │ │ │ │ ├── EntityOperatorReconciler.java
│ │ │ │ │ ├── KafkaAssemblyOperator.java
│ │ │ │ │ ├── KafkaBridgeAssemblyOperator.java
│ │ │ │ │ ├── KafkaClusterCreator.java
│ │ │ │ │ ├── KafkaConnectApiImpl.java
│ │ │ │ │ ├── KafkaConnectApi.java
│ │ │ │ │ ├── KafkaConnectAssemblyOperator.java
│ │ │ │ │ ├── KafkaConnectMigration.java
│ │ │ │ │ ├── KafkaConnectRoller.java
│ │ │ │ │ ├── KafkaExporterReconciler.java
│ │ │ │ │ ├── KafkaListenersReconciler.java
│ │ │ │ │ ├── KafkaMirrorMaker2AssemblyOperator.java
│ │ │ │ │ ├── KafkaMirrorMakerAssemblyOperator.java
│ │ │ │ │ ├── KafkaRebalanceAssemblyOperator.java
│ │ │ │ │ ├── KafkaReconciler.java
│ │ │ │ │ ├── KRaftMetadataManager.java
│ │ │ │ │ ├── KRaftVersionChangeCreator.java
│ │ │ │ │ ├── ManualPodCleaner.java
│ │ │ │ │ ├── MetricsAndLoggingUtils.java
│ │ │ │ │ ├── Operator.java
│ │ │ │ │ ├── PvcReconciler.java
│ │ │ │ │ ├── ReconcilerUtils.java
│ │ │ │ │ ├── ReconnectingWatcher.java
│ │ │ │ │ ├── StrimziPodSetController.java
│ │ │ │ │ ├── VersionChangeCreator.java
│ │ │ │ │ ├── ZooKeeperReconciler.java
│ │ │ │ │ └── ZooKeeperVersionChangeCreator.java
│ │ │ │ └── resource
│ │ │ │ ├── BrokerState.java
│ │ │ │ ├── ConcurrentDeletionException.java
│ │ │ │ ├── cruisecontrol
│ │ │ │ │ ├── AbstractRebalanceOptions.java
│ │ │ │ │ ├── AddBrokerOptions.java
│ │ │ │ │ ├── CruiseControlApiImpl.java
│ │ │ │ │ ├── CruiseControlApi.java
│ │ │ │ │ ├── CruiseControlRebalanceResponse.java
│ │ │ │ │ ├── CruiseControlResponse.java
│ │ │ │ │ ├── CruiseControlRestException.java
│ │ │ │ │ ├── CruiseControlRetriableConnectionException.java
│ │ │ │ │ ├── PathBuilder.java
│ │ │ │ │ ├── RebalanceOptions.java
│ │ │ │ │ └── RemoveBrokerOptions.java
│ │ │ │ ├── DefaultZooKeeperAdminProvider.java
│ │ │ │ ├── DefaultZookeeperScalerProvider.java
│ │ │ │ ├── events
│ │ │ │ │ └── KubernetesRestartEventPublisher.java
│ │ │ │ ├── HttpClientUtils.java
│ │ │ │ ├── KafkaAgentClient.java
│ │ │ │ ├── KafkaAvailability.java
│ │ │ │ ├── KafkaBrokerConfigurationDiff.java
│ │ │ │ ├── KafkaBrokerLoggingConfigurationDiff.java
│ │ │ │ ├── KafkaQuorumCheck.java
│ │ │ │ ├── KafkaRoller.java
│ │ │ │ ├── ResourceOperatorSupplier.java
│ │ │ │ ├── StatefulSetDiff.java
│ │ │ │ ├── StatefulSetOperator.java
│ │ │ │ ├── ZooKeeperAdminProvider.java
│ │ │ │ ├── ZookeeperLeaderFinder.java
│ │ │ │ ├── ZooKeeperRoller.java
│ │ │ │ ├── ZookeeperScaler.java
│ │ │ │ ├── ZookeeperScalerProvider.java
│ │ │ │ └── ZookeeperScalingException.java
│ │ │ └── PlatformFeaturesAvailability.java
│ │ ├── resources
│ │ │ ├── cluster-roles
│ │ │ │ ├── 020-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 021-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 022-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 023-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 030-ClusterRole-strimzi-kafka-broker.yaml
│ │ │ │ ├── 031-ClusterRole-strimzi-entity-operator.yaml
│ │ │ │ └── 033-ClusterRole-strimzi-kafka-client.yaml
│ │ │ ├── default-logging
│ │ │ │ ├── CruiseControl.properties
│ │ │ │ ├── EntityTopicOperator.properties
│ │ │ │ ├── EntityUserOperator.properties
│ │ │ │ ├── KafkaBridgeCluster.properties
│ │ │ │ ├── KafkaCluster.properties
│ │ │ │ ├── KafkaConnectCluster.properties
│ │ │ │ ├── KafkaMirrorMaker2Cluster.properties
│ │ │ │ ├── KafkaMirrorMakerCluster.properties
│ │ │ │ └── ZookeeperCluster.properties
│ │ │ └── log4j2.properties
│ │ └── resources-filtered
│ └── test
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ └── operator
│ │ └── cluster
│ │ ├── ClusterOperatorConfigTest.java
│ │ ├── ClusterOperatorTest.java
│ │ ├── FeatureGatesTest.java
│ │ ├── JSONObjectMatchers.java
│ │ ├── KafkaVersionTestUtils.java
│ │ ├── leaderelection
│ │ │ ├── LeaderElectionManagerConfigTest.java
│ │ │ ├── LeaderElectionManagerIT.java
│ │ │ └── LeaderElectionManagerMockTest.java
│ │ ├── MainIT.java
│ │ ├── model
│ │ │ ├── AbstractConfigurationTest.java
│ │ │ ├── AbstractModelTest.java
│ │ │ ├── AuthenticationUtilsTest.java
│ │ │ ├── CertUtilsTest.java
│ │ │ ├── ClusterCaRenewalTest.java
│ │ │ ├── ClusterCaTest.java
│ │ │ ├── ConfigMapUtilsTest.java
│ │ │ ├── ContainerUtilsTest.java
│ │ │ ├── cruisecontrol
│ │ │ │ └── CruiseControlMetricsReporterTest.java
│ │ │ ├── CruiseControlTest.java
│ │ │ ├── DnsNameGeneratorTest.java
│ │ │ ├── EntityOperatorTest.java
│ │ │ ├── EntityTopicOperatorTest.java
│ │ │ ├── EntityUserOperatorTest.java
│ │ │ ├── jmx
│ │ │ │ └── JmxModelTest.java
│ │ │ ├── JvmOptionUtilsTest.java
│ │ │ ├── KafkaBridgeClusterTest.java
│ │ │ ├── KafkaBrokerConfigurationBuilderTest.java
│ │ │ ├── KafkaClusterOAuthValidationTest.java
│ │ │ ├── KafkaClusterPodSetTest.java
│ │ │ ├── KafkaClusterTest.java
│ │ │ ├── KafkaClusterWithKRaftTest.java
│ │ │ ├── KafkaClusterWithPoolsTest.java
│ │ │ ├── KafkaConfigurationTests.java
│ │ │ ├── KafkaConnectBuildTest.java
│ │ │ ├── KafkaConnectBuildUtilsTest.java
│ │ │ ├── KafkaConnectClusterTest.java
│ │ │ ├── KafkaConnectDockerfileTest.java
│ │ │ ├── KafkaExporterTest.java
│ │ │ ├── KafkaMirrorMaker2ClusterTest.java
│ │ │ ├── KafkaMirrorMaker2ConnectorsTest.java
│ │ │ ├── KafkaMirrorMakerClusterTest.java
│ │ │ ├── KafkaPoolTest.java
│ │ │ ├── KafkaSpecCheckerTest.java
│ │ │ ├── KafkaSpecCheckerWithNodePoolsTest.java
│ │ │ ├── KafkaVersionTest.java
│ │ │ ├── KRaftUtilsTest.java
│ │ │ ├── ListenersUtilsTest.java
│ │ │ ├── ListenersValidatorTest.java
│ │ │ ├── logging
│ │ │ │ ├── LoggingModelTest.java
│ │ │ │ └── LoggingUtilsTest.java
│ │ │ ├── metrics
│ │ │ │ └── MetricsModelTest.java
│ │ │ ├── MockSharedEnvironmentProvider.java
│ │ │ ├── ModelUtilsResourcesTest.java
│ │ │ ├── ModelUtilsTest.java
│ │ │ ├── NetworkPolicyUtilsTest.java
│ │ │ ├── nodepools
│ │ │ │ ├── NodeIdAssignorTest.java
│ │ │ │ ├── NodeIdRangeTest.java
│ │ │ │ └── VirtualNodePoolConverterTest.java
│ │ │ ├── NodePoolUtilsTest.java
│ │ │ ├── PersistentVolumeClaimUtilsTest.java
│ │ │ ├── PodDisruptionBudgetUtilsTest.java
│ │ │ ├── PodRevisionTest.java
│ │ │ ├── PodSetUtilsTest.java
│ │ │ ├── ProbeUtilsTest.java
│ │ │ ├── QuantitiesTest.java
│ │ │ ├── RbacUtilsTest.java
│ │ │ ├── ResourceTester.java
│ │ │ ├── RestartReasonTest.java
│ │ │ ├── securityprofiles
│ │ │ │ ├── BaselinePodSecurityProviderTest.java
│ │ │ │ ├── PodSecurityProviderFactoryTest.java
│ │ │ │ └── RestrictedPodSecurityProviderTest.java
│ │ │ ├── ServiceAccountUtilsTest.java
│ │ │ ├── ServiceUtilsTest.java
│ │ │ ├── StatusDiffTest.java
│ │ │ ├── StorageDiffTest.java
│ │ │ ├── StorageUtilsTest.java
│ │ │ ├── TemplateUtilsTest.java
│ │ │ ├── VolumeUtilsTest.java
│ │ │ ├── WorkloadUtilsTest.java
│ │ │ ├── ZookeeperClusterPodSetTest.java
│ │ │ ├── ZookeeperClusterTest.java
│ │ │ └── ZooKeeperSpecCheckerTest.java
│ │ ├── operator
│ │ │ ├── assembly
│ │ │ │ ├── AbstractOperatorTest.java
│ │ │ │ ├── AbstractResourceStateMatchers.java
│ │ │ │ ├── BrokersInUseCheckTest.java
│ │ │ │ ├── CaReconcilerTest.java
│ │ │ │ ├── CertificateRenewalTest.java
│ │ │ │ ├── ConnectCluster.java
│ │ │ │ ├── ConnectorMockTest.java
│ │ │ │ ├── CruiseControlReconcilerTest.java
│ │ │ │ ├── EntityOperatorReconcilerTest.java
│ │ │ │ ├── JbodStorageMockTest.java
│ │ │ │ ├── KafkaAssemblyOperatorCustomCertMockTest.java
│ │ │ │ ├── KafkaAssemblyOperatorManualRollingUpdatesTest.java
│ │ │ │ ├── KafkaAssemblyOperatorMockTest.java
│ │ │ │ ├── KafkaAssemblyOperatorNodePoolWatcherTest.java
│ │ │ │ ├── KafkaAssemblyOperatorNonParametrizedTest.java
│ │ │ │ ├── KafkaAssemblyOperatorPodSetTest.java
│ │ │ │ ├── KafkaAssemblyOperatorTest.java
│ │ │ │ ├── KafkaAssemblyOperatorWithKRaftTest.java
│ │ │ │ ├── KafkaAssemblyOperatorWithPoolsKRaftMockTest.java
│ │ │ │ ├── KafkaAssemblyOperatorWithPoolsMockTest.java
│ │ │ │ ├── KafkaAssemblyOperatorWithPoolsTest.java
│ │ │ │ ├── KafkaBridgeAssemblyOperatorTest.java
│ │ │ │ ├── KafkaClusterCreatorTest.java
│ │ │ │ ├── KafkaConnectApiImplTest.java
│ │ │ │ ├── KafkaConnectApiIT.java
│ │ │ │ ├── KafkaConnectApiMockTest.java
│ │ │ │ ├── KafkaConnectAssemblyOperatorConnectorAutoRestartTest.java
│ │ │ │ ├── KafkaConnectAssemblyOperatorMockTest.java
│ │ │ │ ├── KafkaConnectAssemblyOperatorPodSetTest.java
│ │ │ │ ├── KafkaConnectBuildAssemblyOperatorKubeTest.java
│ │ │ │ ├── KafkaConnectBuildAssemblyOperatorOpenShiftTest.java
│ │ │ │ ├── KafkaConnectMigrationTest.java
│ │ │ │ ├── KafkaConnectorIT.java
│ │ │ │ ├── KafkaConnectRollerTest.java
│ │ │ │ ├── KafkaExporterReconcilerTest.java
│ │ │ │ ├── KafkaListenerReconcilerClusterIPTest.java
│ │ │ │ ├── KafkaListenerReconcilerSkipBootstrapLoadBalancerTest.java
│ │ │ │ ├── KafkaMirrorMaker2AssemblyOperatorMockTest.java
│ │ │ │ ├── KafkaMirrorMaker2AssemblyOperatorPodSetTest.java
│ │ │ │ ├── KafkaMirrorMakerAssemblyOperatorTest.java
│ │ │ │ ├── KafkaRebalanceAssemblyOperatorTest.java
│ │ │ │ ├── KafkaRebalanceStateMachineTest.java
│ │ │ │ ├── KafkaRebalanceStatusTest.java
│ │ │ │ ├── KafkaReconcilerStatusTest.java
│ │ │ │ ├── KafkaReconcilerUpgradeDowngradeTest.java
│ │ │ │ ├── KafkaStatusTest.java
│ │ │ │ ├── KafkaUpgradeDowngradeMockTest.java
│ │ │ │ ├── KafkaUpgradeDowngradeWithKRaftMockTest.java
│ │ │ │ ├── KRaftMetadataManagerTest.java
│ │ │ │ ├── KRaftVersionChangeCreatorTest.java
│ │ │ │ ├── ManualPodCleanerTest.java
│ │ │ │ ├── MetricsAndLoggingUtilsTest.java
│ │ │ │ ├── OperatorMetricsTest.java
│ │ │ │ ├── PartialRollingUpdateMockTest.java
│ │ │ │ ├── PvcReconcilerTest.java
│ │ │ │ ├── ReconcilerUtilsTest.java
│ │ │ │ ├── ReconnectingWatcherMockTest.java
│ │ │ │ ├── StrimziPodSetControllerIT.java
│ │ │ │ ├── StrimziPodSetControllerMockTest.java
│ │ │ │ ├── TestingConnector.java
│ │ │ │ ├── TolerationsIT.java
│ │ │ │ └── ZooKeeperVersionChangeCreatorTest.java
│ │ │ └── resource
│ │ │ ├── cruisecontrol
│ │ │ │ ├── CruiseControlClientTest.java
│ │ │ │ ├── MockCruiseControl.java
│ │ │ │ ├── MockCruiseControlTest.java
│ │ │ │ └── PathBuilderTest.java
│ │ │ ├── events
│ │ │ │ ├── KubernetesRestartEventPublisherIT.java
│ │ │ │ ├── KubernetesRestartEventPublisherTest.java
│ │ │ │ └── KubernetesRestartEventsMockTest.java
│ │ │ ├── KafkaAgentClientTest.java
│ │ │ ├── KafkaAvailabilityTest.java
│ │ │ ├── KafkaBrokerConfigurationDiffTest.java
│ │ │ ├── KafkaBrokerLoggingConfigurationDiffTest.java
│ │ │ ├── KafkaQuorumCheckTest.java
│ │ │ ├── KafkaRollerTest.java
│ │ │ ├── StatefulSetDiffTest.java
│ │ │ ├── StatefulSetOperatorTest.java
│ │ │ ├── StatefulSetRollingUpdateTest.java
│ │ │ ├── ZookeeperLeaderFinderTest.java
│ │ │ ├── ZooKeeperRollerTest.java
│ │ │ └── ZookeeperScalerTest.java
│ │ ├── PlatformFeaturesAvailabilityTest.java
│ │ ├── ResourceUtils.java
│ │ └── TestUtils.java
│ └── resources
│ ├── current-kafka-broker.conf
│ ├── desired-kafka-broker.conf
│ ├── io
│ │ └── strimzi
│ │ └── operator
│ │ └── cluster
│ │ ├── model
│ │ │ ├── EntityOperatorTest.withAffinityAndTolerations-DeploymentAffinity.yaml
│ │ │ ├── EntityOperatorTest.withAffinityAndTolerations-DeploymentTolerations.yaml
│ │ │ ├── EntityOperatorTest.withAffinityAndTolerations-Kafka.yaml
│ │ │ ├── fbfd.json
│ │ │ ├── KafkaClusterTest.withAffinityWithoutRack-Kafka.yaml
│ │ │ ├── KafkaClusterTest.withAffinityWithoutRack.yaml
│ │ │ ├── KafkaClusterTest.withRackAndAffinity-Kafka.yaml
│ │ │ ├── KafkaClusterTest.withRackAndAffinityWithMoreTerms-Kafka.yaml
│ │ │ ├── KafkaClusterTest.withRackAndAffinityWithMoreTerms.yaml
│ │ │ ├── KafkaClusterTest.withRackAndAffinity.yaml
│ │ │ ├── KafkaClusterTest.withRackWithoutAffinity-Kafka.yaml
│ │ │ ├── KafkaClusterTest.withRackWithoutAffinity.yaml
│ │ │ ├── KafkaClusterTest.withTolerations-Kafka.yaml
│ │ │ ├── KafkaClusterTest.withTolerations.yaml
│ │ │ ├── KafkaConnectClusterTest.withAffinity-KafkaConnect.yaml
│ │ │ ├── KafkaConnectClusterTest.withAffinity-StrimziPodSet.yaml
│ │ │ ├── KafkaConnectClusterTest.withTolerations-KafkaConnect.yaml
│ │ │ ├── KafkaConnectClusterTest.withTolerations-StrimziPodSet.yaml
│ │ │ ├── KafkaMirrorMaker2ClusterTest.withAffinity-KafkaMirrorMaker2.yaml
│ │ │ ├── KafkaMirrorMaker2ClusterTest.withAffinity-StrimziPodSet.yaml
│ │ │ ├── KafkaMirrorMaker2ClusterTest.withTolerations-KafkaMirrorMaker2.yaml
│ │ │ ├── KafkaMirrorMaker2ClusterTest.withTolerations-StrimziPodSet.yaml
│ │ │ ├── TopicOperatorTest.withAffinity-Deployment.yaml
│ │ │ ├── TopicOperatorTest.withAffinity-Kafka.yaml
│ │ │ ├── ZookeeperClusterTest.withAffinity-Kafka.yaml
│ │ │ ├── ZookeeperClusterTest.withAffinity.yaml
│ │ │ ├── ZookeeperClusterTest.withTolerations-Kafka.yaml
│ │ │ └── ZookeeperClusterTest.withTolerations.yaml
│ │ └── operator
│ │ └── assembly
│ │ ├── clients-ca.crt
│ │ ├── clients-ca.key
│ │ ├── cluster-ca.crt
│ │ ├── cluster-ca.key
│ │ └── CruiseControlJSON
│ │ ├── CC-Broker-not-exist.json
│ │ ├── CC-Rebalance-bad-goals-error.json
│ │ ├── CC-Rebalance-no-goals-in-progress.json
│ │ ├── CC-Rebalance-no-goals.json
│ │ ├── CC-Rebalance-no-goals-verbose.json
│ │ ├── CC-Rebalance-NotEnoughValidWindows-error.json
│ │ ├── CC-State.json
│ │ ├── CC-State-proposal-not-ready.json
│ │ ├── CC-State-verbose.json
│ │ ├── CC-Stop.json
│ │ ├── CC-User-task-rebalance-no-goals-Active.json
│ │ ├── CC-User-task-rebalance-no-goals-completed.json
│ │ ├── CC-User-task-rebalance-no-goals-inExecution.json
│ │ ├── CC-User-task-rebalance-no-goals-verbose-Active.json
│ │ ├── CC-User-task-rebalance-no-goals-verbose-completed.json
│ │ ├── CC-User-task-rebalance-no-goals-verbose-inExecution.json
│ │ ├── CC-User-task-status-completed-with-error.json
│ │ └── CC-User-task-status-fetch-error.json
│ ├── kafka-versions
│ │ ├── kafka-versions-duplicates.yaml
│ │ ├── kafka-versions-nodefault.yaml
│ │ ├── kafka-versions-twodefaults.yaml
│ │ └── kafka-versions-valid.yaml
│ └── log4j2-test.properties
├── CODE_OF_CONDUCT.md
├── config-model
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── io
│ │ └── strimzi
│ │ └── kafka
│ │ └── config
│ │ └── model
│ │ ├── ConfigModel.java
│ │ ├── ConfigModels.java
│ │ ├── Scope.java
│ │ └── Type.java
│ └── test
│ └── java
│ └── ConfigModelTest.java
├── config-model-generator
│ ├── build-config-models.sh
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── io
│ └── strimzi
│ └── build
│ └── kafka
│ └── metadata
│ └── KafkaConfigModelGenerator.java
├── CONTRIBUTING.md
├── crd-annotations
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── io
│ │ └── strimzi
│ │ └── api
│ │ └── annotations
│ │ ├── ApiVersion.java
│ │ ├── DeprecatedProperty.java
│ │ ├── DeprecatedType.java
│ │ ├── KubeVersion.java
│ │ └── VersionRange.java
│ └── test
│ └── java
│ └── io
│ └── strimzi
│ └── api
│ └── annotations
│ ├── ApiVersionTest.java
│ └── VersionRangeTest.java
├── crd-generator
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── io
│ │ └── strimzi
│ │ └── crdgenerator
│ │ ├── annotations
│ │ │ ├── AddedIn.java
│ │ │ ├── Crd.java
│ │ │ ├── DescriptionFile.java
│ │ │ ├── Description.java
│ │ │ ├── Example.java
│ │ │ ├── KubeLink.java
│ │ │ ├── Maximum.java
│ │ │ ├── MinimumItems.java
│ │ │ ├── Minimum.java
│ │ │ ├── OneOf.java
│ │ │ ├── Pattern.java
│ │ │ ├── PresentInVersions.java
│ │ │ └── Type.java
│ │ ├── CrdGenerator.java
│ │ ├── DocGenerator.java
│ │ ├── KubeLinker.java
│ │ ├── Linker.java
│ │ ├── Property.java
│ │ ├── PropertyType.java
│ │ └── Schema.java
│ └── test
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ └── crdgenerator
│ │ ├── CrdGeneratorTest.java
│ │ ├── CrdTestUtils.java
│ │ ├── CustomisedEnum.java
│ │ ├── DocGeneratorTest.java
│ │ ├── ExampleCrd.java
│ │ ├── ExampleWithSubresourcesCrd.java
│ │ ├── NormalEnum.java
│ │ ├── PropertyTest.java
│ │ └── VersionedExampleCrd.java
│ └── resources
│ └── io
│ └── strimzi
│ └── crdgenerator
│ ├── simpleTest.adoc
│ ├── simpleTestHelmMetadata.yaml
│ ├── simpleTestWithoutDescriptions.yaml
│ ├── simpleTestWithSubresources.yaml
│ ├── simpleTest.yaml
│ └── versionedTest.yaml
├── development-docs
│ ├── DEBUGGING.md
│ ├── DEV_GUIDE.md
│ ├── KAFKA_VERSIONS.md
│ ├── RELEASE.md
│ └── TESTING.md
├── dist.xml
├── docker-images
│ ├── artifacts
│ │ ├── build.sh
│ │ ├── extract-jars.sh
│ │ ├── find-colliding-classes.sh
│ │ ├── kafka-thirdparty-libs
│ │ │ ├── 3.5.x
│ │ │ │ ├── ignorelist
│ │ │ │ └── pom.xml
│ │ │ ├── 3.6.x
│ │ │ │ ├── ignorelist
│ │ │ │ └── pom.xml
│ │ │ └── cc
│ │ │ └── pom.xml
│ │ └── Makefile
│ ├── base
│ │ ├── Dockerfile
│ │ └── Makefile
│ ├── kafka-based
│ │ ├── build.sh
│ │ ├── find-classpath-collision.sh
│ │ ├── kafka
│ │ │ ├── cruise-control-scripts
│ │ │ │ ├── cruise_control_config_generator.sh
│ │ │ │ ├── cruise_control_healthcheck.sh
│ │ │ │ ├── cruise_control_run.sh
│ │ │ │ ├── cruise_control_tls_prepare_certificates.sh
│ │ │ │ ├── dynamic_resources.sh
│ │ │ │ └── to_bytes.gawk
│ │ │ ├── Dockerfile
│ │ │ ├── exporter-scripts
│ │ │ │ └── kafka_exporter_run.sh
│ │ │ ├── Makefile
│ │ │ ├── scripts
│ │ │ │ ├── dynamic_resources.sh
│ │ │ │ ├── kafka_config_generator.sh
│ │ │ │ ├── kafka_connect_config_generator.sh
│ │ │ │ ├── kafka_connect_run.sh
│ │ │ │ ├── kafka_connect_tls_prepare_certificates.sh
│ │ │ │ ├── kafka_liveness.sh
│ │ │ │ ├── kafka_mirror_maker_2_connector_config_generator.sh
│ │ │ │ ├── kafka_mirror_maker_2_run.sh
│ │ │ │ ├── kafka_mirror_maker_consumer_config_generator.sh
│ │ │ │ ├── kafka_mirror_maker_liveness.sh
│ │ │ │ ├── kafka_mirror_maker_producer_config_generator.sh
│ │ │ │ ├── kafka_mirror_maker_run.sh
│ │ │ │ ├── kafka_mirror_maker_tls_prepare_certificates.sh
│ │ │ │ ├── kafka_readiness_kraft.sh
│ │ │ │ ├── kafka_readiness.sh
│ │ │ │ ├── kafka_run.sh
│ │ │ │ ├── kafka_tls_prepare_certificates.sh
│ │ │ │ ├── set_kafka_gc_options.sh
│ │ │ │ ├── set_kafka_jmx_options.sh
│ │ │ │ ├── tls_utils.sh
│ │ │ │ ├── to_bytes.gawk
│ │ │ │ ├── zookeeper_config_generator.sh
│ │ │ │ ├── zookeeper_healthcheck.sh
│ │ │ │ ├── zookeeper_run.sh
│ │ │ │ └── zookeeper_tls_prepare_certificates.sh
│ │ │ └── stunnel-scripts
│ │ │ ├── entity_operator_stunnel_config_generator.sh
│ │ │ ├── entity_operator_stunnel_pre_stop.sh
│ │ │ ├── entity_operator_stunnel_run.sh
│ │ │ └── stunnel_healthcheck.sh
│ │ └── Makefile
│ ├── kaniko-executor
│ │ └── Makefile
│ ├── Makefile
│ ├── maven-builder
│ │ ├── Dockerfile
│ │ └── Makefile
│ └── operator
│ ├── Dockerfile
│ ├── Makefile
│ └── scripts
│ └── launch_java.sh
├── documentation
│ ├── api
│ │ ├── io.strimzi.api.kafka.model.bridge.KafkaBridgeConsumerSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.bridge.KafkaBridgeHttpConfig.adoc
│ │ ├── io.strimzi.api.kafka.model.bridge.KafkaBridgeProducerSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.bridge.KafkaBridgeSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.common.authentication.KafkaClientAuthenticationOAuth.adoc
│ │ ├── io.strimzi.api.kafka.model.common.authentication.KafkaClientAuthenticationPlain.adoc
│ │ ├── io.strimzi.api.kafka.model.common.authentication.KafkaClientAuthenticationScramSha256.adoc
│ │ ├── io.strimzi.api.kafka.model.common.authentication.KafkaClientAuthenticationScramSha512.adoc
│ │ ├── io.strimzi.api.kafka.model.common.authentication.KafkaClientAuthenticationTls.adoc
│ │ ├── io.strimzi.api.kafka.model.common.ClientTls.adoc
│ │ ├── io.strimzi.api.kafka.model.common.jmx.KafkaJmxOptions.adoc
│ │ ├── io.strimzi.api.kafka.model.common.Rack.adoc
│ │ ├── io.strimzi.api.kafka.model.common.template.ContainerTemplate.adoc
│ │ ├── io.strimzi.api.kafka.model.common.template.DeploymentTemplate.adoc
│ │ ├── io.strimzi.api.kafka.model.common.template.ExternalServiceTemplate.adoc
│ │ ├── io.strimzi.api.kafka.model.common.template.MetadataTemplate.adoc
│ │ ├── io.strimzi.api.kafka.model.common.template.PodDisruptionBudgetTemplate.adoc
│ │ ├── io.strimzi.api.kafka.model.common.template.PodTemplate.adoc
│ │ ├── io.strimzi.api.kafka.model.connect.build.Build.adoc
│ │ ├── io.strimzi.api.kafka.model.connect.ExternalConfiguration.adoc
│ │ ├── io.strimzi.api.kafka.model.connect.KafkaConnectSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.connector.AutoRestart.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.cruisecontrol.CruiseControlSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.entityoperator.EntityTopicOperatorSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.entityoperator.EntityUserOperatorSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.entityoperator.TlsSidecar.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.KafkaAuthorizationCustom.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.KafkaAuthorizationOpa.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.KafkaAuthorizationSimple.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.KafkaClusterSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.listener.GenericKafkaListener.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.listener.GenericKafkaListenerConfiguration.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.listener.GenericKafkaListenerConfigurationBootstrap.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.listener.GenericKafkaListenerConfigurationBroker.adoc
│ │ ├── io.strimzi.api.kafka.model.kafka.listener.KafkaListenerAuthenticationCustom.adoc
│ │ ├── io.strimzi.api.kafka.model.mirrormaker2.KafkaMirrorMaker2ClusterSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.mirrormaker.KafkaMirrorMakerConsumerSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.mirrormaker.KafkaMirrorMakerProducerSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.mirrormaker.KafkaMirrorMakerSpec.adoc
│ │ ├── io.strimzi.api.kafka.model.podset.StrimziPodSet.adoc
│ │ ├── io.strimzi.api.kafka.model.user.acl.AclRule.adoc
│ │ ├── io.strimzi.api.kafka.model.user.KafkaUserQuotas.adoc
│ │ ├── io.strimzi.api.kafka.model.user.KafkaUserTemplate.adoc
│ │ └── io.strimzi.api.kafka.model.zookeeper.ZookeeperClusterSpec.adoc
│ ├── assemblies
│ │ ├── configuring
│ │ │ ├── assembly-config.adoc
│ │ │ ├── assembly-customizing-kubernetes-resources.adoc
│ │ │ ├── assembly-external-config.adoc
│ │ │ ├── assembly-logging-configuration.adoc
│ │ │ ├── assembly-reassign-tool.adoc
│ │ │ ├── assembly-scheduling.adoc
│ │ │ ├── assembly-security-providers.adoc
│ │ │ └── assembly-storage.adoc
│ │ ├── cruise-control
│ │ │ └── assembly-cruise-control-concepts.adoc
│ │ ├── deploying
│ │ │ ├── assembly-deploy-client-access.adoc
│ │ │ ├── assembly-deploy-cluster-operator.adoc
│ │ │ ├── assembly-deploy-intro.adoc
│ │ │ ├── assembly-deploy-intro-custom-resources.adoc
│ │ │ ├── assembly-deploy-intro-operators.adoc
│ │ │ ├── assembly-deploy-kafka-bridge.adoc
│ │ │ ├── assembly-deploy-kafka-cluster.adoc
│ │ │ ├── assembly-deploy-kafka-connect.adoc
│ │ │ ├── assembly-deploy-kafka-connect-with-plugins.adoc
│ │ │ ├── assembly-deploy-kafka-mirror-maker.adoc
│ │ │ ├── assembly-deploy-options.adoc
│ │ │ ├── assembly-deploy-restart-events.adoc
│ │ │ ├── assembly-deploy-standalone-operators.adoc
│ │ │ ├── assembly-deploy-tasks.adoc
│ │ │ ├── assembly-deploy-tasks-prep.adoc
│ │ │ └── assembly-drain-cleaner.adoc
│ │ ├── managing
│ │ │ ├── assembly-cluster-recovery-volume.adoc
│ │ │ ├── assembly-maintenance-time-windows.adoc
│ │ │ ├── assembly-management-tasks.adoc
│ │ │ ├── assembly-rolling-updates.adoc
│ │ │ ├── assembly-tuning-config.adoc
│ │ │ └── assembly-uninstalling.adoc
│ │ ├── metrics
│ │ │ ├── assembly-metrics.adoc
│ │ │ ├── assembly-metrics-config-files.adoc
│ │ │ ├── assembly_metrics-prometheus-deploy.adoc
│ │ │ └── assembly_metrics-prometheus-setup.adoc
│ │ ├── oauth
│ │ │ ├── assembly-managing-policies-permissions-keycloak.adoc
│ │ │ ├── assembly-oauth-authentication.adoc
│ │ │ └── assembly-oauth-authorization.adoc
│ │ ├── operators
│ │ │ ├── assembly-using-multiple-cluster-operators.adoc
│ │ │ ├── assembly-using-the-topic-operator.adoc
│ │ │ └── assembly-using-the-user-operator.adoc
│ │ ├── overview
│ │ │ ├── assembly-configuration-points.adoc
│ │ │ ├── assembly-kafka-components.adoc
│ │ │ ├── assembly-kafka-concepts.adoc
│ │ │ ├── assembly-kafka-connect-components.adoc
│ │ │ ├── assembly-key-features.adoc
│ │ │ ├── assembly-metrics-overview.adoc
│ │ │ ├── assembly-overview-components.adoc
│ │ │ └── assembly-security-overview.adoc
│ │ ├── security
│ │ │ ├── assembly-securing-access.adoc
│ │ │ ├── assembly-securing-kafka.adoc
│ │ │ ├── assembly-securing-kafka-brokers.adoc
│ │ │ ├── assembly-securing-kafka-clients.adoc
│ │ │ ├── assembly-security.adoc
│ │ │ └── assembly-using-your-own-certificates.adoc
│ │ ├── tracing
│ │ │ ├── assembly-distributed-tracing.adoc
│ │ │ └── assembly-distributed-tracing-procedures.adoc
│ │ └── upgrading
│ │ ├── assembly-downgrade.adoc
│ │ ├── assembly-downgrade-zookeeper.adoc
│ │ ├── assembly-upgrade.adoc
│ │ ├── assembly-upgrade-cluster-operator.adoc
│ │ └── assembly-upgrade-zookeeper.adoc
│ ├── configuring
│ │ ├── api
│ │ ├── assemblies
│ │ ├── configuring.adoc
│ │ ├── configuring-docinfo.xml
│ │ ├── examples
│ │ ├── images
│ │ ├── modules
│ │ └── shared
│ ├── contributing
│ │ ├── contributing.adoc
│ │ ├── contributor-guide.adoc
│ │ ├── files.adoc
│ │ ├── formatting-guide.adoc
│ │ ├── git-setup-guide.adoc
│ │ ├── git-tips.adoc
│ │ ├── images
│ │ ├── introduction.adoc
│ │ ├── make-tooling.adoc
│ │ ├── README.md
│ │ ├── shared
│ │ └── styleguide.adoc
│ ├── deploying
│ │ ├── assemblies
│ │ ├── deploying.adoc
│ │ ├── deploying-docinfo.xml
│ │ ├── images
│ │ ├── modules
│ │ └── shared
│ ├── logo
│ │ ├── cncf-color.png
│ │ ├── favicon.ico
│ │ ├── font
│ │ │ └── righteous.zip
│ │ ├── README.md
│ │ ├── strimzi_logo.png
│ │ └── strimzi.png
│ ├── modules
│ │ ├── appendix_crds.adoc
│ │ ├── con-common-configuration-properties.adoc
│ │ ├── configuring
│ │ │ ├── con-applying-termination-grace-period.adoc
│ │ │ ├── con-config-custom-security-providers.adoc
│ │ │ ├── con-config-examples.adoc
│ │ │ ├── con-config-high-volume-messages.adoc
│ │ │ ├── con-config-kafka.adoc
│ │ │ ├── con-config-kafka-bridge.adoc
│ │ │ ├── con-config-kafka-connect.adoc
│ │ │ ├── con-config-kafka-connect-multiple-instances.adoc
│ │ │ ├── con-config-mirrormaker2-acls.adoc
│ │ │ ├── con-config-mirrormaker2.adoc
│ │ │ ├── con-config-mirrormaker2-connectors.adoc
│ │ │ ├── con-config-mirrormaker2-producers-consumers.adoc
│ │ │ ├── con-config-mirrormaker2-tasks-max.adoc
│ │ │ ├── con-config-mirrormaker.adoc
│ │ │ ├── con-config-mm2-multiple-instances.adoc
│ │ │ ├── con-config-node-pool-roles.adoc
│ │ │ ├── con-config-node-pools.adoc
│ │ │ ├── con-config-platform-security-providers.adoc
│ │ │ ├── con-config-resources.adoc
│ │ │ ├── con-config-security-providers.adoc
│ │ │ ├── con-configuration-points-configmaps.adoc
│ │ │ ├── con-configuring-topic-operator.adoc
│ │ │ ├── con-configuring-user-operator.adoc
│ │ │ ├── con-considerations-for-data-storage.adoc
│ │ │ ├── con-customizing-image-pull-policy.adoc
│ │ │ ├── con-external-config.adoc
│ │ │ ├── con-maintenance-time-window-definition.adoc
│ │ │ ├── con-maintenance-time-windows-overview.adoc
│ │ │ ├── con-partition-reassignment.adoc
│ │ │ ├── con-pod-management.adoc
│ │ │ ├── con-scaling-kafka-clusters.adoc
│ │ │ ├── con-schema-overview.adoc
│ │ │ ├── con-skipping-scale-down-checks.adoc
│ │ │ ├── con-zookeeper-default-config.adoc
│ │ │ ├── proc-adding-volumes-to-jbod-storage.adoc
│ │ │ ├── proc-changing-topic-replicas.adoc
│ │ │ ├── proc-config-kafka-connect-user-authorization.adoc
│ │ │ ├── proc-config-mirrormaker2-securing-connection.adoc
│ │ │ ├── proc-config-restricted-security-provider.adoc
│ │ │ ├── proc-configuring-maintenance-time-windows.adoc
│ │ │ ├── proc-connecting-to-zookeeper.adoc
│ │ │ ├── proc-creating-configmap.adoc
│ │ │ ├── proc-creating-logging-filters.adoc
│ │ │ ├── proc-dedicated-nodes.adoc
│ │ │ ├── proc-generating-reassignment-json-files.adoc
│ │ │ ├── proc-loading-config-from-config-map.adoc
│ │ │ ├── proc-loading-config-from-env-vars.adoc
│ │ │ ├── proc-loading-config-from-file.adoc
│ │ │ ├── proc-loading-config-from-files.adoc
│ │ │ ├── proc-managing-node-pools-ids.adoc
│ │ │ ├── proc-managing-storage-affinity-node-pools.adoc
│ │ │ ├── proc-managing-storage-node-pools.adoc
│ │ │ ├── proc-manual-delete-pod-pvc-kafka.adoc
│ │ │ ├── proc-manual-delete-pod-pvc-zookeeper.adoc
│ │ │ ├── proc-manual-restart-connector.adoc
│ │ │ ├── proc-manual-restart-connector-task.adoc
│ │ │ ├── proc-manual-restart-mirrormaker2-connector.adoc
│ │ │ ├── proc-manual-restart-mirrormaker2-connector-task.adoc
│ │ │ ├── proc-manual-stop-pause-connector.adoc
│ │ │ ├── proc-manual-stop-pause-mirrormaker2-connector.adoc
│ │ │ ├── proc-migrating-clusters-node-pools.adoc
│ │ │ ├── proc-moving-node-pools.adoc
│ │ │ ├── proc-removing-volumes-from-jbod-storage.adoc
│ │ │ ├── proc-resizing-persistent-volumes.adoc
│ │ │ ├── proc-scaling-down-a-kafka-cluster.adoc
│ │ │ ├── proc-scaling-down-node-pools.adoc
│ │ │ ├── proc-scaling-up-a-kafka-cluster.adoc
│ │ │ ├── proc-scaling-up-node-pools.adoc
│ │ │ ├── proc-scheduling-based-on-other-pods.adoc
│ │ │ ├── proc-scheduling-brokers-on-different-worker-nodes.adoc
│ │ │ ├── proc-scheduling-deployment-to-node-using-node-affinity.adoc
│ │ │ ├── ref-affinity.adoc
│ │ │ ├── ref-config-list-of-kafka-connect-resources.adoc
│ │ │ ├── ref-kafka-entity-operator.adoc
│ │ │ ├── ref-list-of-kafka-bridge-resources.adoc
│ │ │ ├── ref-list-of-kafka-cluster-resources.adoc
│ │ │ ├── ref-list-of-mirrormaker2-resources.adoc
│ │ │ ├── ref-list-of-mirrormaker-resources.adoc
│ │ │ ├── ref-storage-ephemeral.adoc
│ │ │ ├── ref-storage-jbod.adoc
│ │ │ ├── ref-storage-persistent.adoc
│ │ │ └── snip-reassign-partitions.adoc
│ │ ├── cruise-control
│ │ │ ├── con-cruise-control-description.adoc
│ │ │ ├── con-cruise-control-overview.adoc
│ │ │ ├── con-optimization-goals.adoc
│ │ │ ├── con-optimization-proposals.adoc
│ │ │ ├── con-rebalance-performance.adoc
│ │ │ ├── proc-approving-optimization-proposal.adoc
│ │ │ ├── proc-configuring-deploying-cruise-control.adoc
│ │ │ ├── proc-fixing-problems-with-kafkarebalance.adoc
│ │ │ ├── proc-generating-optimization-proposals.adoc
│ │ │ └── proc-stopping-cluster-rebalance.adoc
│ │ ├── deploying
│ │ │ ├── con-accessing-kafka-bridge-from-outside.adoc
│ │ │ ├── con-deploy-cluster-operator-from-operator-hub.adoc
│ │ │ ├── con-deploy-cluster-operator-watch-options.adoc
│ │ │ ├── con-deploy-container-images.adoc
│ │ │ ├── con-deploy-custom-resources-example.adoc
│ │ │ ├── con-deploy-operator-best-practices.adoc
│ │ │ ├── con-deploy-options-order.adoc
│ │ │ ├── con-deploy-paths.adoc
│ │ │ ├── con-deploy-prereqs.adoc
│ │ │ ├── con-deploy-product-downloads.adoc
│ │ │ ├── con-exposing-kafka-connect-api.adoc
│ │ │ ├── con-fips-support.adoc
│ │ │ ├── con-kafka-bridge-concepts.adoc
│ │ │ ├── con-securing-kafka-connect-api.adoc
│ │ │ ├── con-strimzi-installation-methods.adoc
│ │ │ ├── con-switching-api-to-kafka-connector.adoc
│ │ │ ├── proc-deploy-cluster-operator-helm-chart.adoc
│ │ │ ├── proc-deploy-cluster-operator-watch-multiple-namespaces.adoc
│ │ │ ├── proc-deploy-cluster-operator-watch-namespace.adoc
│ │ │ ├── proc-deploy-cluster-operator-watch-whole-cluster.adoc
│ │ │ ├── proc-deploy-designating-strimzi-administrators.adoc
│ │ │ ├── proc-deploy-example-clients.adoc
│ │ │ ├── proc-deploying-kafkaconnector.adoc
│ │ │ ├── proc-deploy-kafka-bridge.adoc
│ │ │ ├── proc-deploy-kafka-cluster.adoc
│ │ │ ├── proc-deploy-kafka-connect.adoc
│ │ │ ├── proc-deploy-kafka-connect-new-image-from-base.adoc
│ │ │ ├── proc-deploy-kafka-connect-using-kafka-connect-build.adoc
│ │ │ ├── proc-deploy-kafka-mirror-maker.adoc
│ │ │ ├── proc-deploy-kafka-node-pools.adoc
│ │ │ ├── proc-deploy-setup-external-clients.adoc
│ │ │ ├── proc-deploy-topic-operator-standalone.adoc
│ │ │ ├── proc-deploy-topic-operator-with-cluster-operator.adoc
│ │ │ ├── proc-deploy-user-operator-standalone.adoc
│ │ │ ├── proc-deploy-user-operator-with-cluster-operator.adoc
│ │ │ ├── proc-exposing-kafka-bridge-service-local-machine.adoc
│ │ │ ├── proc-operator-restart-events.adoc
│ │ │ ├── proc-uninstalling.adoc
│ │ │ ├── proc-uninstalling-operator-hub.adoc
│ │ │ ├── ref-operator-restart-events-fields.adoc
│ │ │ └── ref-operator-restart-events-reasons.adoc
│ │ ├── drain-cleaner
│ │ │ ├── proc-drain-cleaner-certs.adoc
│ │ │ ├── proc-drain-cleaner-certs-renewals.adoc
│ │ │ ├── proc-drain-cleaner-deploying.adoc
│ │ │ ├── proc-drain-cleaner-deploying-helm-chart.adoc
│ │ │ └── proc-drain-cleaner-using.adoc
│ │ ├── install
│ │ ├── managing
│ │ │ ├── con-broker-config-properties.adoc
│ │ │ ├── con-cluster-loss-recovery.adoc
│ │ │ ├── con-cluster-operator-faqs.adoc
│ │ │ ├── con-consumer-config-properties.adoc
│ │ │ ├── con-custom-resources-info.adoc
│ │ │ ├── con-custom-resources-status.adoc
│ │ │ ├── con-managed-broker-config-properties.adoc
│ │ │ ├── con-namespace-deletion-recovery.adoc
│ │ │ ├── con-producer-config-properties.adoc
│ │ │ ├── con-service-discovery.adoc
│ │ │ ├── proc-accessing-resource-status.adoc
│ │ │ ├── proc-cluster-recovery-volume.adoc
│ │ │ ├── proc-manual-rolling-update-pods.adoc
│ │ │ ├── proc-manual-rolling-update-strimzipodset.adoc
│ │ │ ├── proc-pausing-reconciliation.adoc
│ │ │ └── proc-setting-broker-limits.adoc
│ │ ├── metrics
│ │ │ ├── con_kafka-exporter-lag.adoc
│ │ │ ├── con-metrics-cruise-control.adoc
│ │ │ ├── con_metrics-prometheus-options.adoc
│ │ │ ├── con_metrics-prometheus-resources.adoc
│ │ │ ├── proc_metrics-deploying-prometheus.adoc
│ │ │ ├── proc_metrics-deploying-prometheus-alertmanager.adoc
│ │ │ ├── proc_metrics-deploying-prometheus-operator.adoc
│ │ │ ├── proc_metrics-grafana-dashboard.adoc
│ │ │ ├── proc-metrics-kafka-deploy-options.adoc
│ │ │ ├── ref_metrics-alertmanager-examples.adoc
│ │ │ ├── ref_metrics-dashboards.adoc
│ │ │ └── ref-prometheus-metrics-config.adoc
│ │ ├── oauth
│ │ │ ├── con-kafka-keycloak-authz-models.adoc
│ │ │ ├── con-mapping-keycloak-authz-services-to-kafka-model.adoc
│ │ │ ├── con-oauth-authentication-broker.adoc
│ │ │ ├── con-oauth-authentication-client.adoc
│ │ │ ├── con-oauth-authentication-client-options.adoc
│ │ │ ├── con-oauth-authentication-flow.adoc
│ │ │ ├── con-oauth-authorization-intro.adoc
│ │ │ ├── con-oauth-authorization-mechanism.adoc
│ │ │ ├── con-oauth-config.adoc
│ │ │ ├── con-oauth-reauthentication.adoc
│ │ │ ├── con-oauth-server-examples.adoc
│ │ │ ├── proc-oauth-authentication-broker-config.adoc
│ │ │ ├── proc-oauth-authorization-broker-config.adoc
│ │ │ ├── proc-oauth-authorization-keycloak-example.adoc
│ │ │ ├── proc-oauth-client-config.adoc
│ │ │ ├── proc-oauth-kafka-config.adoc
│ │ │ ├── proc-oauth-server-config.adoc
│ │ │ └── ref-example-permissions-for-kafka-operations.adoc
│ │ ├── operators
│ │ │ ├── con-application-topic-handling.adoc
│ │ │ ├── con-configuring-cluster-operator.adoc
│ │ │ ├── con-configuring-cluster-operator-leader-election.adoc
│ │ │ ├── con-deleting-managed-topics.adoc
│ │ │ ├── con-disabling-topic-deletion.adoc
│ │ │ ├── con-operators-namespaces.adoc
│ │ │ ├── con-operator-topic-names.adoc
│ │ │ ├── con-removing-topic-finalizers.adoc
│ │ │ ├── con-topic-replication.adoc
│ │ │ ├── con-tuning-topic-request-batches.adoc
│ │ │ ├── proc-changing-topic-operator-mode.adoc
│ │ │ ├── proc-configuring-kafka-topic.adoc
│ │ │ ├── proc-configuring-kafka-user.adoc
│ │ │ ├── proc-configuring-multiple-cluster-operators.adoc
│ │ │ ├── proc-configuring-proxy-config-cluster-operator.adoc
│ │ │ ├── proc-converting-managed-topics.adoc
│ │ │ ├── proc-converting-non-managed-topics.adoc
│ │ │ ├── proc-disabling-fips-mode-cluster-operator.adoc
│ │ │ ├── ref-operator-cluster-feature-gate-releases.adoc
│ │ │ ├── ref-operator-cluster-feature-gates.adoc
│ │ │ ├── ref-operator-cluster-logging-configmap.adoc
│ │ │ ├── ref-operator-cluster-rbac-resources.adoc
│ │ │ └── ref-operator-topic.adoc
│ │ ├── overview
│ │ │ ├── con-configuration-points-bridge.adoc
│ │ │ ├── con-configuration-points-broker.adoc
│ │ │ ├── con-configuration-points-common.adoc
│ │ │ ├── con-configuration-points-connect.adoc
│ │ │ ├── con-configuration-points-listener-names.adoc
│ │ │ ├── con-configuration-points-listeners.adoc
│ │ │ ├── con-configuration-points-mirrormaker2.adoc
│ │ │ ├── con-configuration-points-mirrormaker.adoc
│ │ │ ├── con-configuration-points-node-pools.adoc
│ │ │ ├── con-configuration-points-resources.adoc
│ │ │ ├── con-feature-gates-overview.adoc
│ │ │ ├── con-kafka-concepts-components.adoc
│ │ │ ├── con-kafka-concepts-key.adoc
│ │ │ ├── con-kafka-concepts-producers-consumers.adoc
│ │ │ ├── con-key-features-kafka.adoc
│ │ │ ├── con-key-features-kafka-connect.adoc
│ │ │ ├── con-key-features-product.adoc
│ │ │ ├── con-metrics-overview-tools.adoc
│ │ │ ├── con-overview-components-cluster-operator.adoc
│ │ │ ├── con-overview-components-kafka-bridge.adoc
│ │ │ ├── con-overview-components-kafka-bridge-clients.adoc
│ │ │ ├── con-overview-components-topic-operator.adoc
│ │ │ ├── con-overview-components-user-operator.adoc
│ │ │ ├── con-overview-mirrormaker2.adoc
│ │ │ ├── con-security-configuration-authentication.adoc
│ │ │ ├── con-security-configuration-authorization.adoc
│ │ │ ├── con-security-configuration-encryption.adoc
│ │ │ └── con-security-configuration-fips.adoc
│ │ ├── security
│ │ │ ├── con-certificate-authorities.adoc
│ │ │ ├── con-certificate-renewal.adoc
│ │ │ ├── con-securing-client-authentication.adoc
│ │ │ ├── con-securing-client-authorization.adoc
│ │ │ ├── con-securing-client-labels.adoc
│ │ │ ├── con-securing-kafka-authentication.adoc
│ │ │ ├── con-securing-kafka-authorization.adoc
│ │ │ ├── proc-accessing-kafka-using-ingress.adoc
│ │ │ ├── proc-accessing-kafka-using-loadbalancers.adoc
│ │ │ ├── proc-accessing-kafka-using-nodeports.adoc
│ │ │ ├── proc-accessing-kafka-using-routes.adoc
│ │ │ ├── proc-configuring-external-clients-to-trust-cluster-ca.adoc
│ │ │ ├── proc-configuring-internal-clients-to-trust-cluster-ca.adoc
│ │ │ ├── proc-configuring-secure-kafka-user.adoc
│ │ │ ├── proc-installing-certs-per-listener.adoc
│ │ │ ├── proc-installing-your-own-ca-certificates.adoc
│ │ │ ├── proc-recovering-expired-ca-certs.adoc
│ │ │ ├── proc-renewing-ca-certs-manually.adoc
│ │ │ ├── proc-renewing-your-own-ca-certificates.adoc
│ │ │ ├── proc-replacing-private-keys.adoc
│ │ │ ├── proc-replacing-your-own-private-keys.adoc
│ │ │ ├── proc-restricting-access-to-listeners-using-network-policies.adoc
│ │ │ ├── proc-securing-kafka.adoc
│ │ │ ├── ref-alternative-subjects-certs-for-listeners.adoc
│ │ │ └── ref-certificates-and-secrets.adoc
│ │ ├── snip-images.adoc
│ │ ├── snip-kafka-versions.adoc
│ │ ├── snip-version-correlation.adoc
│ │ ├── tracing
│ │ │ ├── con-distributed-tracing-description.adoc
│ │ │ ├── con-overview-tracing.adoc
│ │ │ ├── proc-configuring-tracers-kafka-clients.adoc
│ │ │ ├── proc-enabling-tracing-in-connect-mirror-maker-bridge-resources.adoc
│ │ │ ├── proc-enabling-tracing-type.adoc
│ │ │ ├── proc-instrumenting-kafka-streams-with-tracers.adoc
│ │ │ ├── proc-instrumenting-producers-consumers-tracing.adoc
│ │ │ ├── ref-tracing-environment-variables.adoc
│ │ │ └── ref-tracing-span-names.adoc
│ │ └── upgrading
│ │ ├── con-downgrade-target-version.adoc
│ │ ├── con-upgrade-cluster.adoc
│ │ ├── con-upgrade-older-clients.adoc
│ │ ├── con-upgrade-paths.adoc
│ │ ├── con-upgrade-sequence.adoc
│ │ ├── con-upgrade-status.adoc
│ │ ├── con-upgrade-strategies-for-upgrading-clients.adoc
│ │ ├── con-upgrade-versions-and-images.adoc
│ │ ├── proc-downgrade-cluster-operator.adoc
│ │ ├── proc-downgrade-kafka-kraft.adoc
│ │ ├── proc-downgrade-kafka-zookeeper.adoc
│ │ ├── proc-switching-to-FIPS-mode-when-upgrading-Strimzi.adoc
│ │ ├── proc-upgrade-cluster-operator.adoc
│ │ ├── proc-upgrade-kafka-kraft.adoc
│ │ ├── proc-upgrade-kafka-zookeeper.adoc
│ │ └── ref-upgrade-kafka-versions.adoc
│ ├── overview
│ │ ├── assemblies
│ │ ├── images
│ │ ├── modules
│ │ ├── overview.adoc
│ │ ├── overview-docinfo.xml
│ │ └── shared
│ ├── README.md
│ ├── shared
│ │ ├── attributes.adoc
│ │ ├── images
│ │ │ ├── cluster-operator.png
│ │ │ ├── common-config-resources.png
│ │ │ ├── consumer-lag.png
│ │ │ ├── image_con-overview-distributed-tracing.png
│ │ │ ├── kafka-authorization-config-options.png
│ │ │ ├── kafka-bridge.png
│ │ │ ├── listener-config-options.png
│ │ │ ├── mirrormaker.png
│ │ │ ├── mirrormaker-renaming.png
│ │ │ ├── oauth-introspection-endpoint-long-token.png
│ │ │ ├── oauth-introspection-endpoint.png
│ │ │ ├── oauth-jwt-signature.png
│ │ │ ├── oauth-jwt-signature-token.png
│ │ │ ├── oauth-plain-access-token.png
│ │ │ ├── oauth-plain-client-id.png
│ │ │ ├── operators.png
│ │ │ ├── overview
│ │ │ │ ├── kafka-concepts-kafka-connector.png
│ │ │ │ ├── kafka-concepts-key-concepts.png
│ │ │ │ ├── kafka-concepts-partitions.png
│ │ │ │ ├── kafka-concepts-producer-consumer.png
│ │ │ │ ├── kafka-concepts-sink-connector.png
│ │ │ │ ├── kafka-concepts-source-connector.png
│ │ │ │ └── kafka-concepts-supporting-components.png
│ │ │ ├── rack-config-availability-zones.png
│ │ │ ├── secure_communication_kraft.png
│ │ │ ├── secure_communication_zookeeper.png
│ │ │ ├── topic-operator.png
│ │ │ └── tuning
│ │ │ ├── broker-tuning-compaction-after.png
│ │ │ ├── broker-tuning-compaction-before.png
│ │ │ ├── broker-tuning-compaction-retention.png
│ │ │ ├── broker-tuning-messaging-inline.png
│ │ │ └── broker-tuning-messaging-reference.png
│ │ ├── ref-document-conventions.adoc
│ │ ├── revision-info.adoc
│ │ ├── snip-cluster-operator-namespace-sed.adoc
│ │ ├── snip-example-source-connector-config.adoc
│ │ ├── snip-intro-connectors.adoc
│ │ ├── snip-intro-custom-resources.adoc
│ │ ├── snip-intro-kafka-deployment.adoc
│ │ ├── snip-intro-text.adoc
│ │ └── version-dependent-attrs.adoc
│ ├── snip-images.sh
│ ├── snip-kafka-versions.sh
│ └── version-dependent-attrs.sh
├── examples
│ ├── bridge
│ │ └── kafka-bridge.yaml
│ ├── connect
│ │ ├── kafka-connect-build.yaml
│ │ ├── kafka-connect.yaml
│ │ └── source-connector.yaml
│ ├── cruise-control
│ │ ├── kafka-cruise-control-with-goals.yaml
│ │ ├── kafka-cruise-control.yaml
│ │ ├── kafka-rebalance-add-brokers.yaml
│ │ ├── kafka-rebalance-full.yaml
│ │ ├── kafka-rebalance-remove-brokers.yaml
│ │ └── kafka-rebalance-with-goals.yaml
│ ├── DO_NOT_EDIT.md
│ ├── kafka
│ │ ├── kafka-ephemeral-single.yaml
│ │ ├── kafka-ephemeral.yaml
│ │ ├── kafka-jbod.yaml
│ │ ├── kafka-persistent-single.yaml
│ │ ├── kafka-persistent.yaml
│ │ └── nodepools
│ │ ├── kafka-with-dual-role-kraft-nodes.yaml
│ │ ├── kafka-with-kraft-ephemeral.yaml
│ │ ├── kafka-with-kraft.yaml
│ │ ├── kafka.yaml
│ │ └── README.md
│ ├── metrics
│ │ ├── grafana-dashboards
│ │ │ ├── strimzi-cruise-control.json
│ │ │ ├── strimzi-kafka-bridge.json
│ │ │ ├── strimzi-kafka-connect.json
│ │ │ ├── strimzi-kafka-exporter.json
│ │ │ ├── strimzi-kafka.json
│ │ │ ├── strimzi-kafka-mirror-maker-2.json
│ │ │ ├── strimzi-kafka-oauth.json
│ │ │ ├── strimzi-kraft.json
│ │ │ ├── strimzi-operators.json
│ │ │ └── strimzi-zookeeper.json
│ │ ├── grafana-install
│ │ │ └── grafana.yaml
│ │ ├── kafka-bridge-metrics.yaml
│ │ ├── kafka-connect-metrics.yaml
│ │ ├── kafka-cruise-control-metrics.yaml
│ │ ├── kafka-metrics.yaml
│ │ ├── kafka-mirror-maker-2-metrics.yaml
│ │ ├── oauth-metrics.yaml
│ │ ├── prometheus-additional-properties
│ │ │ └── prometheus-additional.yaml
│ │ ├── prometheus-alertmanager-config
│ │ │ └── alert-manager-config.yaml
│ │ └── prometheus-install
│ │ ├── alert-manager.yaml
│ │ ├── prometheus-rules.yaml
│ │ ├── prometheus.yaml
│ │ └── strimzi-pod-monitor.yaml
│ ├── mirror-maker
│ │ ├── kafka-mirror-maker-2-custom-replication-policy.yaml
│ │ ├── kafka-mirror-maker-2-sync-groups.yaml
│ │ ├── kafka-mirror-maker-2-tls.yaml
│ │ ├── kafka-mirror-maker-2.yaml
│ │ ├── kafka-mirror-maker-tls.yaml
│ │ ├── kafka-mirror-maker.yaml
│ │ ├── kafka-source.yaml
│ │ └── kafka-target.yaml
│ ├── README.md
│ ├── security
│ │ ├── keycloak-authorization
│ │ │ ├── kafka-authz-realm.json
│ │ │ ├── kafka-ephemeral-oauth-single-keycloak-authz-metrics.yaml
│ │ │ ├── kafka-ephemeral-oauth-single-keycloak-authz.yaml
│ │ │ └── README.md
│ │ ├── scram-sha-512-auth
│ │ │ ├── bridge.yaml
│ │ │ ├── connect.yaml
│ │ │ ├── kafka.yaml
│ │ │ ├── mirror-maker-2.yaml
│ │ │ ├── topic.yaml
│ │ │ └── user.yaml
│ │ └── tls-auth
│ │ ├── bridge.yaml
│ │ ├── connect.yaml
│ │ ├── kafka.yaml
│ │ ├── mirror-maker-2.yaml
│ │ ├── topic.yaml
│ │ └── user.yaml
│ ├── topic
│ │ └── kafka-topic.yaml
│ └── user
│ └── kafka-user.yaml
├── GOVERNANCE.md
├── helm-charts
│ ├── DO_NOT_EDIT.md
│ └── helm3
│ └── strimzi-kafka-operator
│ ├── Chart.yaml
│ ├── crds
│ │ ├── 040-Crd-kafka.yaml
│ │ ├── 041-Crd-kafkaconnect.yaml
│ │ ├── 042-Crd-strimzipodset.yaml
│ │ ├── 043-Crd-kafkatopic.yaml
│ │ ├── 044-Crd-kafkauser.yaml
│ │ ├── 045-Crd-kafkamirrormaker.yaml
│ │ ├── 046-Crd-kafkabridge.yaml
│ │ ├── 047-Crd-kafkaconnector.yaml
│ │ ├── 048-Crd-kafkamirrormaker2.yaml
│ │ ├── 049-Crd-kafkarebalance.yaml
│ │ └── 04A-Crd-kafkanodepool.yaml
│ ├── files
│ │ └── grafana-dashboards
│ │ ├── strimzi-cruise-control.json
│ │ ├── strimzi-kafka-bridge.json
│ │ ├── strimzi-kafka-connect.json
│ │ ├── strimzi-kafka-exporter.json
│ │ ├── strimzi-kafka.json
│ │ ├── strimzi-kafka-mirror-maker-2.json
│ │ ├── strimzi-kafka-oauth.json
│ │ ├── strimzi-kraft.json
│ │ ├── strimzi-operators.json
│ │ └── strimzi-zookeeper.json
│ ├── OWNERS
│ ├── README.md
│ ├── templates
│ │ ├── 010-ServiceAccount-strimzi-cluster-operator.yaml
│ │ ├── 020-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 020-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 021-ClusterRoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 021-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 022-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 022-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 023-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 023-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 030-ClusterRoleBinding-strimzi-cluster-operator-kafka-broker-delegation.yaml
│ │ ├── 030-ClusterRole-strimzi-kafka-broker.yaml
│ │ ├── 031-ClusterRole-strimzi-entity-operator.yaml
│ │ ├── 031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml
│ │ ├── 033-ClusterRoleBinding-strimzi-cluster-operator-kafka-client-delegation.yaml
│ │ ├── 033-ClusterRole-strimzi-kafka-client.yaml
│ │ ├── 050-ConfigMap-strimzi-cluster-operator.yaml
│ │ ├── 051-PodDisruptionBudget-strimzi-cluster-operator.yaml
│ │ ├── 060-Deployment-strimzi-cluster-operator.yaml
│ │ ├── 070-ClusterRole-strimzi-admin.yaml
│ │ ├── 080-ClusterRole-strimzi-view.yaml
│ │ ├── 090-ConfigMap-strimzi-grafana-dashboards.yaml
│ │ ├── _helpers.tpl
│ │ ├── _kafka_image_map.tpl
│ │ └── NOTES.txt
│ └── values.yaml
├── install
│ ├── canary
│ │ ├── 000-ServiceAccount.yaml
│ │ ├── 010-Service.yaml
│ │ ├── 020-Deployment.yaml
│ │ └── README.md
│ ├── cluster-operator
│ │ ├── 010-ServiceAccount-strimzi-cluster-operator.yaml
│ │ ├── 020-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 020-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 021-ClusterRoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 021-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 022-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 022-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 023-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 023-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 030-ClusterRoleBinding-strimzi-cluster-operator-kafka-broker-delegation.yaml
│ │ ├── 030-ClusterRole-strimzi-kafka-broker.yaml
│ │ ├── 031-ClusterRole-strimzi-entity-operator.yaml
│ │ ├── 031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml
│ │ ├── 033-ClusterRoleBinding-strimzi-cluster-operator-kafka-client-delegation.yaml
│ │ ├── 033-ClusterRole-strimzi-kafka-client.yaml
│ │ ├── 040-Crd-kafka.yaml
│ │ ├── 041-Crd-kafkaconnect.yaml
│ │ ├── 042-Crd-strimzipodset.yaml
│ │ ├── 043-Crd-kafkatopic.yaml
│ │ ├── 044-Crd-kafkauser.yaml
│ │ ├── 045-Crd-kafkamirrormaker.yaml
│ │ ├── 046-Crd-kafkabridge.yaml
│ │ ├── 047-Crd-kafkaconnector.yaml
│ │ ├── 048-Crd-kafkamirrormaker2.yaml
│ │ ├── 049-Crd-kafkarebalance.yaml
│ │ ├── 04A-Crd-kafkanodepool.yaml
│ │ ├── 050-ConfigMap-strimzi-cluster-operator.yaml
│ │ └── 060-Deployment-strimzi-cluster-operator.yaml
│ ├── DO_NOT_EDIT.md
│ ├── drain-cleaner
│ │ ├── certmanager
│ │ │ ├── 000-Namespace.yaml
│ │ │ ├── 010-ServiceAccount.yaml
│ │ │ ├── 020-ClusterRole.yaml
│ │ │ ├── 021-Role.yaml
│ │ │ ├── 030-ClusterRoleBinding.yaml
│ │ │ ├── 031-RoleBinding.yaml
│ │ │ ├── 040-Issuer.yaml
│ │ │ ├── 041-Certificate.yaml
│ │ │ ├── 050-Service.yaml
│ │ │ ├── 060-Deployment.yaml
│ │ │ └── 070-ValidatingWebhookConfiguration.yaml
│ │ ├── kubernetes
│ │ │ ├── 000-Namespace.yaml
│ │ │ ├── 010-ServiceAccount.yaml
│ │ │ ├── 020-ClusterRole.yaml
│ │ │ ├── 021-Role.yaml
│ │ │ ├── 030-ClusterRoleBinding.yaml
│ │ │ ├── 031-RoleBinding.yaml
│ │ │ ├── 040-Secret.yaml
│ │ │ ├── 050-Service.yaml
│ │ │ ├── 060-Deployment.yaml
│ │ │ ├── 070-ValidatingWebhookConfiguration.yaml
│ │ │ └── README.md
│ │ ├── openshift
│ │ │ ├── 000-Namespace.yaml
│ │ │ ├── 010-ServiceAccount.yaml
│ │ │ ├── 020-ClusterRole.yaml
│ │ │ ├── 021-Role.yaml
│ │ │ ├── 030-ClusterRoleBinding.yaml
│ │ │ ├── 031-RoleBinding.yaml
│ │ │ ├── 050-Service.yaml
│ │ │ ├── 060-Deployment.yaml
│ │ │ └── 070-ValidatingWebhookConfiguration.yaml
│ │ └── README.md
│ ├── strimzi-admin
│ │ ├── 010-ClusterRole-strimzi-admin.yaml
│ │ └── 020-ClusterRole-strimzi-view.yaml
│ ├── topic-operator
│ │ ├── 01-ServiceAccount-strimzi-topic-operator.yaml
│ │ ├── 02-Role-strimzi-topic-operator.yaml
│ │ ├── 03-RoleBinding-strimzi-topic-operator.yaml
│ │ ├── 04-Crd-kafkatopic.yaml
│ │ └── 05-Deployment-strimzi-topic-operator.yaml
│ └── user-operator
│ ├── 01-ServiceAccount-strimzi-user-operator.yaml
│ ├── 02-Role-strimzi-user-operator.yaml
│ ├── 03-RoleBinding-strimzi-user-operator.yaml
│ ├── 04-Crd-kafkauser.yaml
│ └── 05-Deployment-strimzi-user-operator.yaml
├── kafka-agent
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── io
│ │ └── strimzi
│ │ └── kafka
│ │ └── agent
│ │ └── KafkaAgent.java
│ └── test
│ └── java
│ └── io
│ └── strimzi
│ └── kafka
│ └── agent
│ └── KafkaAgentTest.java
├── kafka-init
│ ├── Makefile
│ ├── pom.xml
│ ├── scripts
│ │ └── kafka_init_run.sh
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── io
│ │ │ └── strimzi
│ │ │ └── kafka
│ │ │ └── init
│ │ │ ├── InitWriterConfig.java
│ │ │ ├── InitWriter.java
│ │ │ └── Main.java
│ │ └── resources
│ │ └── log4j2.properties
│ └── test
│ └── java
│ └── io
│ └── strimzi
│ └── kafka
│ └── init
│ ├── InitWriterConfigTest.java
│ └── InitWriterTest.java
├── KAFKA_VERSION_SUPPORT.md
├── kafka-versions.yaml
├── LICENSE
├── MAINTAINERS
├── Makefile
├── Makefile.docker
├── Makefile.maven
├── Makefile.os
├── mirror-maker-agent
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── io
│ └── strimzi
│ └── mirrormaker
│ └── agent
│ └── MirrorMakerAgent.java
├── mockkube
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── io
│ │ │ └── strimzi
│ │ │ └── test
│ │ │ └── mockkube2
│ │ │ ├── controllers
│ │ │ │ ├── AbstractMockController.java
│ │ │ │ ├── MockDeploymentController.java
│ │ │ │ ├── MockPodController.java
│ │ │ │ └── MockServiceController.java
│ │ │ ├── logging
│ │ │ │ ├── JulLoggingConfiguration.java
│ │ │ │ └── StdOutConsoleHandler.java
│ │ │ └── MockKube2.java
│ │ └── resources
│ │ └── jul-logging.properties
│ └── test
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ └── test
│ │ └── mockkube2
│ │ └── MockKube2ControllersTest.java
│ └── resources
│ └── log4j2.properties
├── operator-common
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ ├── main
│ │ └── java
│ │ └── io
│ │ └── strimzi
│ │ └── operator
│ │ └── common
│ │ ├── AdminClientProvider.java
│ │ ├── Annotations.java
│ │ ├── BackOff.java
│ │ ├── controller
│ │ │ ├── AbstractControllerLoop.java
│ │ │ ├── ControllerQueue.java
│ │ │ ├── DESIGN.md
│ │ │ ├── ReconciliationLockManager.java
│ │ │ └── SimplifiedReconciliation.java
│ │ ├── DefaultAdminClientProvider.java
│ │ ├── http
│ │ │ ├── HealthCheckAndMetricsServer.java
│ │ │ ├── Liveness.java
│ │ │ └── Readiness.java
│ │ ├── InformerUtils.java
│ │ ├── InvalidConfigurationException.java
│ │ ├── MaxAttemptsExceededException.java
│ │ ├── metrics
│ │ │ ├── ControllerMetricsHolder.java
│ │ │ ├── MetricsHolder.java
│ │ │ └── OperatorMetricsHolder.java
│ │ ├── MetricsProvider.java
│ │ ├── MicrometerMetricsProvider.java
│ │ ├── model
│ │ │ ├── AbstractJsonDiff.java
│ │ │ ├── Ca.java
│ │ │ ├── ClientsCa.java
│ │ │ ├── cruisecontrol
│ │ │ │ ├── CruiseControlConfigurationParameters.java
│ │ │ │ ├── CruiseControlEndpoints.java
│ │ │ │ ├── CruiseControlGoals.java
│ │ │ │ ├── CruiseControlLoadParameters.java
│ │ │ │ ├── CruiseControlParameters.java
│ │ │ │ ├── CruiseControlRebalanceKeys.java
│ │ │ │ └── CruiseControlUserTaskStatus.java
│ │ │ ├── InvalidConfigParameterException.java
│ │ │ ├── InvalidResourceException.java
│ │ │ ├── Labels.java
│ │ │ ├── NamespaceAndName.java
│ │ │ ├── NodeUtils.java
│ │ │ ├── OrderedProperties.java
│ │ │ ├── PasswordGenerator.java
│ │ │ ├── ResourceVisitor.java
│ │ │ ├── StatusDiff.java
│ │ │ ├── StatusUtils.java
│ │ │ └── ValidationVisitor.java
│ │ ├── operator
│ │ │ └── resource
│ │ │ ├── AbstractNamespacedResourceOperator.java
│ │ │ ├── AbstractNonNamespacedResourceOperator.java
│ │ │ ├── AbstractReadyNamespacedResourceOperator.java
│ │ │ ├── AbstractResourceOperator.java
│ │ │ ├── AbstractScalableNamespacedResourceOperator.java
│ │ │ ├── AbstractWatchableNamespacedResourceOperator.java
│ │ │ ├── AbstractWatchableStatusedNamespacedResourceOperator.java
│ │ │ ├── BuildConfigOperator.java
│ │ │ ├── BuildOperator.java
│ │ │ ├── ClusterRoleBindingOperator.java
│ │ │ ├── ClusterRoleOperator.java
│ │ │ ├── concurrent
│ │ │ │ ├── AbstractNamespacedResourceOperator.java
│ │ │ │ ├── AbstractResourceOperator.java
│ │ │ │ ├── AbstractWatchableNamespacedResourceOperator.java
│ │ │ │ ├── AbstractWatchableStatusedNamespacedResourceOperator.java
│ │ │ │ ├── CrdOperator.java
│ │ │ │ ├── ResourceSupport.java
│ │ │ │ └── SecretOperator.java
│ │ │ ├── ConfigMapOperator.java
│ │ │ ├── ConfigParameter.java
│ │ │ ├── ConfigParameterParser.java
│ │ │ ├── CrdOperator.java
│ │ │ ├── DeploymentConfigOperator.java
│ │ │ ├── DeploymentOperator.java
│ │ │ ├── EndpointOperator.java
│ │ │ ├── ImageStreamOperator.java
│ │ │ ├── IngressOperator.java
│ │ │ ├── NetworkPolicyOperator.java
│ │ │ ├── NodeOperator.java
│ │ │ ├── NoStackTraceTimeoutException.java
│ │ │ ├── PodDisruptionBudgetOperator.java
│ │ │ ├── PodOperator.java
│ │ │ ├── PvcOperator.java
│ │ │ ├── ReconcileResult.java
│ │ │ ├── ResourceDiff.java
│ │ │ ├── ResourceSupport.java
│ │ │ ├── RoleBindingOperator.java
│ │ │ ├── RoleOperator.java
│ │ │ ├── RouteOperator.java
│ │ │ ├── SecretOperator.java
│ │ │ ├── ServiceAccountOperator.java
│ │ │ ├── ServiceOperator.java
│ │ │ ├── StorageClassOperator.java
│ │ │ ├── StrimziPodSetOperator.java
│ │ │ └── TimeoutException.java
│ │ ├── OperatorKubernetesClientBuilder.java
│ │ ├── ReconciliationException.java
│ │ ├── Reconciliation.java
│ │ ├── ReconciliationLogger.java
│ │ ├── ShutdownHook.java
│ │ ├── Util.java
│ │ └── VertxUtil.java
│ └── test
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ ├── operator
│ │ │ └── common
│ │ │ ├── BackOffTest.java
│ │ │ ├── controller
│ │ │ │ ├── ControllerQueueTest.java
│ │ │ │ ├── ReconciliationLockManagerTest.java
│ │ │ │ └── SimplifiedReconciliationTest.java
│ │ │ ├── http
│ │ │ │ └── HealthCheckAndMetricsServerTest.java
│ │ │ ├── model
│ │ │ │ ├── LabelsTest.java
│ │ │ │ ├── NamespaceAndNameTest.java
│ │ │ │ ├── NodeUtilsTest.java
│ │ │ │ ├── OrderedPropertiesTest.java
│ │ │ │ ├── PasswordGeneratorTest.java
│ │ │ │ ├── ResourceVisitorTest.java
│ │ │ │ └── ValidationVisitorTest.java
│ │ │ ├── operator
│ │ │ │ ├── MockCertManager.java
│ │ │ │ └── resource
│ │ │ │ ├── AbstractCustomResourceOperatorIT.java
│ │ │ │ ├── AbstractNamespacedResourceOperatorIT.java
│ │ │ │ ├── AbstractNamespacedResourceOperatorTest.java
│ │ │ │ ├── AbstractNonNamespacedResourceOperatorIT.java
│ │ │ │ ├── AbstractNonNamespacedResourceOperatorTest.java
│ │ │ │ ├── AbstractReadyResourceOperatorTest.java
│ │ │ │ ├── BuildConfigOperatorTest.java
│ │ │ │ ├── BuildOperatorTest.java
│ │ │ │ ├── ClusterRoleBindingOperatorIT.java
│ │ │ │ ├── ClusterRoleBindingOperatorTest.java
│ │ │ │ ├── ClusterRoleOperatorIT.java
│ │ │ │ ├── ClusterRoleOperatorTest.java
│ │ │ │ ├── concurrent
│ │ │ │ │ ├── AbstractCustomResourceOperatorIT.java
│ │ │ │ │ ├── AbstractNamespacedResourceOperatorIT.java
│ │ │ │ │ ├── AbstractNamespacedResourceOperatorTest.java
│ │ │ │ │ ├── KafkaUserCrdOperatorIT.java
│ │ │ │ │ ├── SecretOperatorIT.java
│ │ │ │ │ └── SecretOperatorTest.java
│ │ │ │ ├── ConfigMapOperatorTest.java
│ │ │ │ ├── DeploymentConfigOperatorTest.java
│ │ │ │ ├── DeploymentOperatorTest.java
│ │ │ │ ├── EndpointOperatorTest.java
│ │ │ │ ├── ImageStreamOperatorTest.java
│ │ │ │ ├── IngressOperatorTest.java
│ │ │ │ ├── KafkaBridgeCrdOperatorIT.java
│ │ │ │ ├── KafkaConnectCrdOperatorIT.java
│ │ │ │ ├── KafkaConnectorCrdOperatorIT.java
│ │ │ │ ├── KafkaCrdOperatorIT.java
│ │ │ │ ├── KafkaCrdOperatorTest.java
│ │ │ │ ├── KafkaMirrorMaker2CrdOperatorIT.java
│ │ │ │ ├── KafkaMirrorMakerCrdOperatorIT.java
│ │ │ │ ├── NodeOperatorIT.java
│ │ │ │ ├── NodeOperatorTest.java
│ │ │ │ ├── PodDisruptionBudgetOperatorTest.java
│ │ │ │ ├── PodOperatorMockTest.java
│ │ │ │ ├── PodOperatorTest.java
│ │ │ │ ├── PvcOperatorTest.java
│ │ │ │ ├── RoleBindingOperatorIT.java
│ │ │ │ ├── RoleBindingOperatorTest.java
│ │ │ │ ├── RoleOperatorIT.java
│ │ │ │ ├── RoleOperatorTest.java
│ │ │ │ ├── RouteOperatorTest.java
│ │ │ │ ├── ScalableResourceOperatorTest.java
│ │ │ │ ├── SecretOperatorTest.java
│ │ │ │ ├── ServiceAccountOperatorIT.java
│ │ │ │ ├── ServiceAccountOperatorTest.java
│ │ │ │ ├── ServiceOperatorIT.java
│ │ │ │ ├── ServiceOperatorTest.java
│ │ │ │ ├── StorageClassOperatorIT.java
│ │ │ │ ├── StorageClassOperatorTest.java
│ │ │ │ └── StrimziPodSetCrdOperatorIT.java
│ │ │ ├── OperatorKubernetesClientBuilderTest.java
│ │ │ ├── ShutdownHookTest.java
│ │ │ ├── UtilTest.java
│ │ │ └── VertxUtilTest.java
│ │ └── test
│ │ └── logging
│ │ └── TestLogger.java
│ └── resources
│ ├── CLIENTS_CERT.pem
│ ├── CLIENTS_CERT.str
│ ├── CLIENTS_KEY.pem
│ ├── CLUSTER_CERT.pem
│ ├── CLUSTER_CERT.str
│ ├── CLUSTER_KEY.pem
│ ├── example2.yaml
│ ├── example.yaml
│ └── log4j2.properties
├── packaging
│ ├── examples
│ │ ├── bridge
│ │ │ └── kafka-bridge.yaml
│ │ ├── connect
│ │ │ ├── kafka-connect-build.yaml
│ │ │ ├── kafka-connect.yaml
│ │ │ └── source-connector.yaml
│ │ ├── cruise-control
│ │ │ ├── kafka-cruise-control-with-goals.yaml
│ │ │ ├── kafka-cruise-control.yaml
│ │ │ ├── kafka-rebalance-add-brokers.yaml
│ │ │ ├── kafka-rebalance-full.yaml
│ │ │ ├── kafka-rebalance-remove-brokers.yaml
│ │ │ └── kafka-rebalance-with-goals.yaml
│ │ ├── kafka
│ │ │ ├── kafka-ephemeral-single.yaml
│ │ │ ├── kafka-ephemeral.yaml
│ │ │ ├── kafka-jbod.yaml
│ │ │ ├── kafka-persistent-single.yaml
│ │ │ ├── kafka-persistent.yaml
│ │ │ ├── kafka-with-node-pools.yaml
│ │ │ └── kraft
│ │ │ ├── kafka-ephemeral.yaml
│ │ │ ├── kafka-with-dual-role-nodes.yaml
│ │ │ ├── kafka.yaml
│ │ │ └── README.md
│ │ ├── Makefile
│ │ ├── metrics
│ │ │ ├── grafana-dashboards
│ │ │ │ ├── strimzi-cruise-control.json
│ │ │ │ ├── strimzi-kafka-bridge.json
│ │ │ │ ├── strimzi-kafka-connect.json
│ │ │ │ ├── strimzi-kafka-exporter.json
│ │ │ │ ├── strimzi-kafka.json
│ │ │ │ ├── strimzi-kafka-mirror-maker-2.json
│ │ │ │ ├── strimzi-kafka-oauth.json
│ │ │ │ ├── strimzi-kraft.json
│ │ │ │ ├── strimzi-operators.json
│ │ │ │ └── strimzi-zookeeper.json
│ │ │ ├── grafana-install
│ │ │ │ └── grafana.yaml
│ │ │ ├── kafka-bridge-metrics.yaml
│ │ │ ├── kafka-connect-metrics.yaml
│ │ │ ├── kafka-cruise-control-metrics.yaml
│ │ │ ├── kafka-metrics.yaml
│ │ │ ├── kafka-mirror-maker-2-metrics.yaml
│ │ │ ├── oauth-metrics.yaml
│ │ │ ├── prometheus-additional-properties
│ │ │ │ └── prometheus-additional.yaml
│ │ │ ├── prometheus-alertmanager-config
│ │ │ │ └── alert-manager-config.yaml
│ │ │ └── prometheus-install
│ │ │ ├── alert-manager.yaml
│ │ │ ├── prometheus-rules.yaml
│ │ │ ├── prometheus.yaml
│ │ │ └── strimzi-pod-monitor.yaml
│ │ ├── mirror-maker
│ │ │ ├── kafka-mirror-maker-2-custom-replication-policy.yaml
│ │ │ ├── kafka-mirror-maker-2-sync-groups.yaml
│ │ │ ├── kafka-mirror-maker-2-tls.yaml
│ │ │ ├── kafka-mirror-maker-2.yaml
│ │ │ ├── kafka-mirror-maker-tls.yaml
│ │ │ ├── kafka-mirror-maker.yaml
│ │ │ ├── kafka-source.yaml
│ │ │ └── kafka-target.yaml
│ │ ├── README.md
│ │ ├── security
│ │ │ ├── keycloak-authorization
│ │ │ │ ├── kafka-authz-realm.json
│ │ │ │ ├── kafka-ephemeral-oauth-single-keycloak-authz-metrics.yaml
│ │ │ │ ├── kafka-ephemeral-oauth-single-keycloak-authz.yaml
│ │ │ │ └── README.md
│ │ │ ├── scram-sha-512-auth
│ │ │ │ ├── bridge.yaml
│ │ │ │ ├── connect.yaml
│ │ │ │ ├── kafka.yaml
│ │ │ │ ├── mirror-maker-2.yaml
│ │ │ │ ├── topic.yaml
│ │ │ │ └── user.yaml
│ │ │ └── tls-auth
│ │ │ ├── bridge.yaml
│ │ │ ├── connect.yaml
│ │ │ ├── kafka.yaml
│ │ │ ├── mirror-maker-2.yaml
│ │ │ ├── topic.yaml
│ │ │ └── user.yaml
│ │ ├── topic
│ │ │ └── kafka-topic.yaml
│ │ └── user
│ │ └── kafka-user.yaml
│ ├── helm-charts
│ │ ├── helm3
│ │ │ ├── Makefile
│ │ │ └── strimzi-kafka-operator
│ │ │ ├── Chart.yaml
│ │ │ ├── crds
│ │ │ │ ├── 040-Crd-kafka.yaml
│ │ │ │ ├── 041-Crd-kafkaconnect.yaml
│ │ │ │ ├── 042-Crd-strimzipodset.yaml
│ │ │ │ ├── 043-Crd-kafkatopic.yaml
│ │ │ │ ├── 044-Crd-kafkauser.yaml
│ │ │ │ ├── 045-Crd-kafkamirrormaker.yaml
│ │ │ │ ├── 046-Crd-kafkabridge.yaml
│ │ │ │ ├── 047-Crd-kafkaconnector.yaml
│ │ │ │ ├── 048-Crd-kafkamirrormaker2.yaml
│ │ │ │ ├── 049-Crd-kafkarebalance.yaml
│ │ │ │ └── 04A-Crd-kafkanodepool.yaml
│ │ │ ├── files
│ │ │ │ └── grafana-dashboards
│ │ │ │ ├── strimzi-cruise-control.json
│ │ │ │ ├── strimzi-kafka-bridge.json
│ │ │ │ ├── strimzi-kafka-connect.json
│ │ │ │ ├── strimzi-kafka-exporter.json
│ │ │ │ ├── strimzi-kafka.json
│ │ │ │ ├── strimzi-kafka-mirror-maker-2.json
│ │ │ │ ├── strimzi-kafka-oauth.json
│ │ │ │ ├── strimzi-kraft.json
│ │ │ │ ├── strimzi-operators.json
│ │ │ │ └── strimzi-zookeeper.json
│ │ │ ├── OWNERS
│ │ │ ├── README.md
│ │ │ ├── templates
│ │ │ │ ├── 010-ServiceAccount-strimzi-cluster-operator.yaml
│ │ │ │ ├── 020-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 020-RoleBinding-strimzi-cluster-operator.yaml
│ │ │ │ ├── 021-ClusterRoleBinding-strimzi-cluster-operator.yaml
│ │ │ │ ├── 021-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 022-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 022-RoleBinding-strimzi-cluster-operator.yaml
│ │ │ │ ├── 023-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ │ │ ├── 023-RoleBinding-strimzi-cluster-operator.yaml
│ │ │ │ ├── 030-ClusterRoleBinding-strimzi-cluster-operator-kafka-broker-delegation.yaml
│ │ │ │ ├── 030-ClusterRole-strimzi-kafka-broker.yaml
│ │ │ │ ├── 031-ClusterRole-strimzi-entity-operator.yaml
│ │ │ │ ├── 031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml
│ │ │ │ ├── 033-ClusterRoleBinding-strimzi-cluster-operator-kafka-client-delegation.yaml
│ │ │ │ ├── 033-ClusterRole-strimzi-kafka-client.yaml
│ │ │ │ ├── 050-ConfigMap-strimzi-cluster-operator.yaml
│ │ │ │ ├── 051-PodDisruptionBudget-strimzi-cluster-operator.yaml
│ │ │ │ ├── 060-Deployment-strimzi-cluster-operator.yaml
│ │ │ │ ├── 070-ClusterRole-strimzi-admin.yaml
│ │ │ │ ├── 080-ClusterRole-strimzi-view.yaml
│ │ │ │ ├── 090-ConfigMap-strimzi-grafana-dashboards.yaml
│ │ │ │ ├── _helpers.tpl
│ │ │ │ ├── _kafka_image_map.tpl
│ │ │ │ └── NOTES.txt
│ │ │ └── values.yaml
│ │ └── kafka-version-tpl.sh
│ └── install
│ ├── canary
│ │ ├── 000-ServiceAccount.yaml
│ │ ├── 010-Service.yaml
│ │ ├── 020-Deployment.yaml
│ │ └── README.md
│ ├── cluster-operator
│ │ ├── 010-ServiceAccount-strimzi-cluster-operator.yaml
│ │ ├── 020-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 020-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 021-ClusterRoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 021-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 022-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 022-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 023-ClusterRole-strimzi-cluster-operator-role.yaml
│ │ ├── 023-RoleBinding-strimzi-cluster-operator.yaml
│ │ ├── 030-ClusterRoleBinding-strimzi-cluster-operator-kafka-broker-delegation.yaml
│ │ ├── 030-ClusterRole-strimzi-kafka-broker.yaml
│ │ ├── 031-ClusterRole-strimzi-entity-operator.yaml
│ │ ├── 031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml
│ │ ├── 033-ClusterRoleBinding-strimzi-cluster-operator-kafka-client-delegation.yaml
│ │ ├── 033-ClusterRole-strimzi-kafka-client.yaml
│ │ ├── 040-Crd-kafka.yaml
│ │ ├── 041-Crd-kafkaconnect.yaml
│ │ ├── 042-Crd-strimzipodset.yaml
│ │ ├── 043-Crd-kafkatopic.yaml
│ │ ├── 044-Crd-kafkauser.yaml
│ │ ├── 045-Crd-kafkamirrormaker.yaml
│ │ ├── 046-Crd-kafkabridge.yaml
│ │ ├── 047-Crd-kafkaconnector.yaml
│ │ ├── 048-Crd-kafkamirrormaker2.yaml
│ │ ├── 049-Crd-kafkarebalance.yaml
│ │ ├── 04A-Crd-kafkanodepool.yaml
│ │ ├── 050-ConfigMap-strimzi-cluster-operator.yaml
│ │ └── 060-Deployment-strimzi-cluster-operator.yaml
│ ├── drain-cleaner
│ │ ├── certmanager
│ │ │ ├── 000-Namespace.yaml
│ │ │ ├── 010-ServiceAccount.yaml
│ │ │ ├── 020-ClusterRole.yaml
│ │ │ ├── 021-Role.yaml
│ │ │ ├── 030-ClusterRoleBinding.yaml
│ │ │ ├── 031-RoleBinding.yaml
│ │ │ ├── 040-Issuer.yaml
│ │ │ ├── 041-Certificate.yaml
│ │ │ ├── 050-Service.yaml
│ │ │ ├── 060-Deployment.yaml
│ │ │ └── 070-ValidatingWebhookConfiguration.yaml
│ │ ├── kubernetes
│ │ │ ├── 000-Namespace.yaml
│ │ │ ├── 010-ServiceAccount.yaml
│ │ │ ├── 020-ClusterRole.yaml
│ │ │ ├── 021-Role.yaml
│ │ │ ├── 030-ClusterRoleBinding.yaml
│ │ │ ├── 031-RoleBinding.yaml
│ │ │ ├── 040-Secret.yaml
│ │ │ ├── 050-Service.yaml
│ │ │ ├── 060-Deployment.yaml
│ │ │ ├── 070-ValidatingWebhookConfiguration.yaml
│ │ │ └── README.md
│ │ ├── openshift
│ │ │ ├── 000-Namespace.yaml
│ │ │ ├── 010-ServiceAccount.yaml
│ │ │ ├── 020-ClusterRole.yaml
│ │ │ ├── 021-Role.yaml
│ │ │ ├── 030-ClusterRoleBinding.yaml
│ │ │ ├── 031-RoleBinding.yaml
│ │ │ ├── 050-Service.yaml
│ │ │ ├── 060-Deployment.yaml
│ │ │ └── 070-ValidatingWebhookConfiguration.yaml
│ │ └── README.md
│ ├── Makefile
│ ├── strimzi-admin
│ │ ├── 010-ClusterRole-strimzi-admin.yaml
│ │ └── 020-ClusterRole-strimzi-view.yaml
│ ├── topic-operator
│ │ ├── 01-ServiceAccount-strimzi-topic-operator.yaml
│ │ ├── 02-Role-strimzi-topic-operator.yaml
│ │ ├── 03-RoleBinding-strimzi-topic-operator.yaml
│ │ ├── 04-Crd-kafkatopic.yaml
│ │ └── 05-Deployment-strimzi-topic-operator.yaml
│ └── user-operator
│ ├── 01-ServiceAccount-strimzi-user-operator.yaml
│ ├── 02-Role-strimzi-user-operator.yaml
│ ├── 03-RoleBinding-strimzi-user-operator.yaml
│ ├── 04-Crd-kafkauser.yaml
│ └── 05-Deployment-strimzi-user-operator.yaml
├── pom.xml
├── README.md
├── release.version
├── systemtest
│ ├── Makefile
│ ├── pom.xml
│ ├── scripts
│ │ ├── results_info.sh
│ │ └── run_tests.sh
│ ├── src
│ │ ├── main
│ │ │ ├── java
│ │ │ │ └── io
│ │ │ │ └── strimzi
│ │ │ │ └── systemtest
│ │ │ │ ├── annotations
│ │ │ │ │ ├── BTONotSupportedCondition.java
│ │ │ │ │ ├── BTONotSupported.java
│ │ │ │ │ ├── FIPSNotSupportedCondition.java
│ │ │ │ │ ├── FIPSNotSupported.java
│ │ │ │ │ ├── IPv6NotSupportedCondition.java
│ │ │ │ │ ├── IPv6NotSupported.java
│ │ │ │ │ ├── IsolatedTest.java
│ │ │ │ │ ├── KindIPv6NotSupportedCondition.java
│ │ │ │ │ ├── KindIPv6NotSupported.java
│ │ │ │ │ ├── KindNotSupportedCondition.java
│ │ │ │ │ ├── KindNotSupported.java
│ │ │ │ │ ├── KRaftNotSupportedCondition.java
│ │ │ │ │ ├── KRaftNotSupported.java
│ │ │ │ │ ├── KRaftWithoutUTONotSupportedCondition.java
│ │ │ │ │ ├── KRaftWithoutUTONotSupported.java
│ │ │ │ │ ├── MicroShiftNotSupportedCondition.java
│ │ │ │ │ ├── MicroShiftNotSupported.java
│ │ │ │ │ ├── MultiNodeClusterOnlyCondition.java
│ │ │ │ │ ├── MultiNodeClusterOnly.java
│ │ │ │ │ ├── NodePoolsNotSupportedCondition.java
│ │ │ │ │ ├── NodePoolsNotSupported.java
│ │ │ │ │ ├── NodePoolsOnlyCondition.java
│ │ │ │ │ ├── NodePoolsOnly.java
│ │ │ │ │ ├── OpenShiftOnlyCondition.java
│ │ │ │ │ ├── OpenShiftOnly.java
│ │ │ │ │ ├── ParallelNamespaceTest.java
│ │ │ │ │ ├── ParallelTest.java
│ │ │ │ │ ├── RequiredMinKubeApiVersionCondition.java
│ │ │ │ │ ├── RequiredMinKubeApiVersion.java
│ │ │ │ │ ├── RequiredMinKubeOrOcpBasedKubeVersion.java
│ │ │ │ │ ├── RequiredMinKubeOrOpenshiftVersionCondition.java
│ │ │ │ │ ├── UTONotSupportedCondition.java
│ │ │ │ │ └── UTONotSupported.java
│ │ │ │ ├── cli
│ │ │ │ │ └── KafkaCmdClient.java
│ │ │ │ ├── enums
│ │ │ │ │ ├── ClusterOperatorInstallType.java
│ │ │ │ │ ├── ClusterOperatorRBACType.java
│ │ │ │ │ ├── ConditionStatus.java
│ │ │ │ │ ├── CustomResourceStatus.java
│ │ │ │ │ ├── DefaultNetworkPolicy.java
│ │ │ │ │ ├── DeploymentTypes.java
│ │ │ │ │ ├── OlmInstallationStrategy.java
│ │ │ │ │ ├── PodSecurityProfile.java
│ │ │ │ │ └── UserAuthType.java
│ │ │ │ ├── Environment.java
│ │ │ │ ├── exceptions
│ │ │ │ │ └── KubernetesClusterUnstableException.java
│ │ │ │ ├── interfaces
│ │ │ │ │ └── IndicativeSentences.java
│ │ │ │ ├── k8s
│ │ │ │ │ └── Events.java
│ │ │ │ ├── kafkaclients
│ │ │ │ │ ├── AbstractKafkaClient.java
│ │ │ │ │ ├── clientproperties
│ │ │ │ │ │ ├── AbstractKafkaClientProperties.java
│ │ │ │ │ │ ├── ConsumerProperties.java
│ │ │ │ │ │ └── ProducerProperties.java
│ │ │ │ │ ├── externalClients
│ │ │ │ │ │ └── ExternalKafkaClient.java
│ │ │ │ │ └── internalClients
│ │ │ │ │ ├── admin
│ │ │ │ │ │ └── AdminClient.java
│ │ │ │ │ ├── BaseClients.java
│ │ │ │ │ ├── BridgeClients.java
│ │ │ │ │ ├── BridgeTracingClients.java
│ │ │ │ │ ├── KafkaClients.java
│ │ │ │ │ ├── KafkaOauthClients.java
│ │ │ │ │ └── KafkaTracingClients.java
│ │ │ │ ├── keycloak
│ │ │ │ │ └── KeycloakInstance.java
│ │ │ │ ├── listeners
│ │ │ │ │ └── ExecutionListener.java
│ │ │ │ ├── logs
│ │ │ │ │ ├── LogCollector.java
│ │ │ │ │ └── TestExecutionWatcher.java
│ │ │ │ ├── matchers
│ │ │ │ │ ├── HasAllOfReasons.java
│ │ │ │ │ ├── HasAnyOfReasons.java
│ │ │ │ │ ├── HasNoneOfReasons.java
│ │ │ │ │ ├── LogHasNoUnexpectedErrors.java
│ │ │ │ │ └── Matchers.java
│ │ │ │ ├── metrics
│ │ │ │ │ └── MetricsCollector.java
│ │ │ │ ├── parallel
│ │ │ │ │ ├── SuiteThreadController.java
│ │ │ │ │ └── TestSuiteNamespaceManager.java
│ │ │ │ ├── resources
│ │ │ │ │ ├── ComponentType.java
│ │ │ │ │ ├── crd
│ │ │ │ │ │ ├── KafkaBridgeResource.java
│ │ │ │ │ │ ├── KafkaClientsResource.java
│ │ │ │ │ │ ├── KafkaConnectorResource.java
│ │ │ │ │ │ ├── KafkaConnectResource.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2Resource.java
│ │ │ │ │ │ ├── KafkaMirrorMakerResource.java
│ │ │ │ │ │ ├── KafkaNodePoolResource.java
│ │ │ │ │ │ ├── KafkaRebalanceResource.java
│ │ │ │ │ │ ├── KafkaResource.java
│ │ │ │ │ │ ├── KafkaTopicResource.java
│ │ │ │ │ │ ├── KafkaUserResource.java
│ │ │ │ │ │ └── StrimziPodSetResource.java
│ │ │ │ │ ├── draincleaner
│ │ │ │ │ │ ├── DrainCleanerResource.java
│ │ │ │ │ │ └── SetupDrainCleaner.java
│ │ │ │ │ ├── jaeger
│ │ │ │ │ │ └── SetupJaeger.java
│ │ │ │ │ ├── keycloak
│ │ │ │ │ │ └── SetupKeycloak.java
│ │ │ │ │ ├── kubernetes
│ │ │ │ │ │ ├── ClusterOperatorCustomResourceDefinition.java
│ │ │ │ │ │ ├── ClusterRoleBindingResource.java
│ │ │ │ │ │ ├── ClusterRoleResource.java
│ │ │ │ │ │ ├── ConfigMapResource.java
│ │ │ │ │ │ ├── DeploymentResource.java
│ │ │ │ │ │ ├── JobResource.java
│ │ │ │ │ │ ├── LeaseResource.java
│ │ │ │ │ │ ├── NetworkPolicyResource.java
│ │ │ │ │ │ ├── RoleBindingResource.java
│ │ │ │ │ │ ├── RoleResource.java
│ │ │ │ │ │ ├── SecretResource.java
│ │ │ │ │ │ ├── ServiceAccountResource.java
│ │ │ │ │ │ ├── ServiceResource.java
│ │ │ │ │ │ └── ValidatingWebhookConfigurationResource.java
│ │ │ │ │ ├── NamespaceManager.java
│ │ │ │ │ ├── openshift
│ │ │ │ │ │ ├── OperatorGroupResource.java
│ │ │ │ │ │ └── SubscriptionResource.java
│ │ │ │ │ ├── operator
│ │ │ │ │ │ ├── BundleResource.java
│ │ │ │ │ │ ├── configuration
│ │ │ │ │ │ │ └── OlmConfiguration.java
│ │ │ │ │ │ ├── SetupClusterOperator.java
│ │ │ │ │ │ └── specific
│ │ │ │ │ │ ├── HelmResource.java
│ │ │ │ │ │ ├── OlmResource.java
│ │ │ │ │ │ └── SpecificResourceType.java
│ │ │ │ │ ├── ResourceCondition.java
│ │ │ │ │ ├── ResourceItem.java
│ │ │ │ │ ├── ResourceManager.java
│ │ │ │ │ ├── ResourceOperation.java
│ │ │ │ │ ├── ResourceType.java
│ │ │ │ │ └── ThrowableRunner.java
│ │ │ │ ├── security
│ │ │ │ │ ├── CertAndKeyFiles.java
│ │ │ │ │ ├── OpenSsl.java
│ │ │ │ │ ├── SystemTestCertAndKeyBuilder.java
│ │ │ │ │ ├── SystemTestCertAndKey.java
│ │ │ │ │ ├── SystemTestCertHolder.java
│ │ │ │ │ └── SystemTestCertManager.java
│ │ │ │ ├── storage
│ │ │ │ │ └── TestStorage.java
│ │ │ │ ├── templates
│ │ │ │ │ ├── crd
│ │ │ │ │ │ ├── KafkaBridgeTemplates.java
│ │ │ │ │ │ ├── KafkaConnectorTemplates.java
│ │ │ │ │ │ ├── KafkaConnectTemplates.java
│ │ │ │ │ │ ├── KafkaMirrorMaker2Templates.java
│ │ │ │ │ │ ├── KafkaMirrorMakerTemplates.java
│ │ │ │ │ │ ├── KafkaNodePoolTemplates.java
│ │ │ │ │ │ ├── KafkaRebalanceTemplates.java
│ │ │ │ │ │ ├── KafkaTemplates.java
│ │ │ │ │ │ ├── KafkaTopicTemplates.java
│ │ │ │ │ │ └── KafkaUserTemplates.java
│ │ │ │ │ ├── kubernetes
│ │ │ │ │ │ ├── ClusterRoleBindingTemplates.java
│ │ │ │ │ │ ├── NetworkPolicyTemplates.java
│ │ │ │ │ │ └── ServiceTemplates.java
│ │ │ │ │ └── specific
│ │ │ │ │ ├── AdminClientTemplates.java
│ │ │ │ │ └── ScraperTemplates.java
│ │ │ │ ├── TestConstants.java
│ │ │ │ ├── tracing
│ │ │ │ │ └── TracingConstants.java
│ │ │ │ ├── upgrade
│ │ │ │ │ ├── BundleVersionModificationData.java
│ │ │ │ │ ├── CommonVersionModificationData.java
│ │ │ │ │ ├── OlmVersionModificationData.java
│ │ │ │ │ ├── UpgradeKafkaVersion.java
│ │ │ │ │ └── VersionModificationDataLoader.java
│ │ │ │ └── utils
│ │ │ │ ├── ClientUtils.java
│ │ │ │ ├── FileUtils.java
│ │ │ │ ├── HttpUtils.java
│ │ │ │ ├── kafkaUtils
│ │ │ │ │ ├── KafkaBridgeUtils.java
│ │ │ │ │ ├── KafkaConnectorUtils.java
│ │ │ │ │ ├── KafkaConnectUtils.java
│ │ │ │ │ ├── KafkaMirrorMaker2Utils.java
│ │ │ │ │ ├── KafkaMirrorMakerUtils.java
│ │ │ │ │ ├── KafkaNodePoolUtils.java
│ │ │ │ │ ├── KafkaRebalanceUtils.java
│ │ │ │ │ ├── KafkaTopicScalabilityUtils.java
│ │ │ │ │ ├── KafkaTopicUtils.java
│ │ │ │ │ ├── KafkaUserUtils.java
│ │ │ │ │ └── KafkaUtils.java
│ │ │ │ ├── kubeUtils
│ │ │ │ │ ├── controllers
│ │ │ │ │ │ ├── ConfigMapUtils.java
│ │ │ │ │ │ ├── DeploymentUtils.java
│ │ │ │ │ │ ├── JobUtils.java
│ │ │ │ │ │ ├── StatefulSetUtils.java
│ │ │ │ │ │ └── StrimziPodSetUtils.java
│ │ │ │ │ └── objects
│ │ │ │ │ ├── NodeUtils.java
│ │ │ │ │ ├── PersistentVolumeClaimUtils.java
│ │ │ │ │ ├── PodUtils.java
│ │ │ │ │ ├── SecretUtils.java
│ │ │ │ │ └── ServiceUtils.java
│ │ │ │ ├── RollingUpdateUtils.java
│ │ │ │ ├── specific
│ │ │ │ │ ├── BridgeUtils.java
│ │ │ │ │ ├── CruiseControlUtils.java
│ │ │ │ │ ├── JmxUtils.java
│ │ │ │ │ ├── KeycloakUtils.java
│ │ │ │ │ ├── MetricsUtils.java
│ │ │ │ │ ├── OlmUtils.java
│ │ │ │ │ ├── ScraperUtils.java
│ │ │ │ │ └── TracingUtils.java
│ │ │ │ ├── StUtils.java
│ │ │ │ └── TestKafkaVersion.java
│ │ │ └── resources
│ │ │ └── log4j2.properties
│ │ ├── rbac
│ │ │ └── role-edit-kafka.yaml
│ │ └── test
│ │ ├── java
│ │ │ └── io
│ │ │ └── strimzi
│ │ │ └── systemtest
│ │ │ ├── AbstractST.java
│ │ │ ├── bridge
│ │ │ │ ├── HttpBridgeCorsST.java
│ │ │ │ ├── HttpBridgeKafkaExternalListenersST.java
│ │ │ │ ├── HttpBridgeScramShaST.java
│ │ │ │ ├── HttpBridgeST.java
│ │ │ │ └── HttpBridgeTlsST.java
│ │ │ ├── connect
│ │ │ │ ├── ConnectBuilderST.java
│ │ │ │ └── ConnectST.java
│ │ │ ├── cruisecontrol
│ │ │ │ ├── CruiseControlApiST.java
│ │ │ │ ├── CruiseControlConfigurationST.java
│ │ │ │ └── CruiseControlST.java
│ │ │ ├── kafka
│ │ │ │ ├── ConfigProviderST.java
│ │ │ │ ├── dynamicconfiguration
│ │ │ │ │ ├── DynamicConfSharedST.java
│ │ │ │ │ └── DynamicConfST.java
│ │ │ │ ├── KafkaNodePoolST.java
│ │ │ │ ├── KafkaST.java
│ │ │ │ ├── KafkaVersionsST.java
│ │ │ │ ├── listeners
│ │ │ │ │ ├── ListenersST.java
│ │ │ │ │ └── MultipleListenersST.java
│ │ │ │ └── QuotasST.java
│ │ │ ├── log
│ │ │ │ ├── LoggingChangeST.java
│ │ │ │ └── LogSettingST.java
│ │ │ ├── metrics
│ │ │ │ ├── JmxST.java
│ │ │ │ └── MetricsST.java
│ │ │ ├── mirrormaker
│ │ │ │ ├── MirrorMaker2ST.java
│ │ │ │ └── MirrorMakerST.java
│ │ │ ├── olm
│ │ │ │ ├── OlmAbstractST.java
│ │ │ │ ├── OlmAllNamespaceST.java
│ │ │ │ └── OlmSingleNamespaceST.java
│ │ │ ├── operators
│ │ │ │ ├── ClusterOperatorRbacST.java
│ │ │ │ ├── CustomResourceStatusST.java
│ │ │ │ ├── FeatureGatesST.java
│ │ │ │ ├── LeaderElectionST.java
│ │ │ │ ├── MultipleClusterOperatorsST.java
│ │ │ │ ├── NamespaceDeletionRecoveryST.java
│ │ │ │ ├── NamespaceRbacScopeOperatorST.java
│ │ │ │ ├── PodSetST.java
│ │ │ │ ├── ReconciliationST.java
│ │ │ │ ├── RecoveryST.java
│ │ │ │ ├── topic
│ │ │ │ │ ├── ThrottlingQuotaST.java
│ │ │ │ │ ├── TopicScalabilityST.java
│ │ │ │ │ └── TopicST.java
│ │ │ │ └── user
│ │ │ │ ├── UserScalabilityST.java
│ │ │ │ └── UserST.java
│ │ │ ├── rollingupdate
│ │ │ │ ├── AlternativeReconcileTriggersST.java
│ │ │ │ ├── KafkaRollerST.java
│ │ │ │ └── RollingUpdateST.java
│ │ │ ├── security
│ │ │ │ ├── custom
│ │ │ │ │ ├── CustomAuthorizerST.java
│ │ │ │ │ └── CustomCaST.java
│ │ │ │ ├── NetworkPoliciesST.java
│ │ │ │ ├── oauth
│ │ │ │ │ ├── OauthAbstractST.java
│ │ │ │ │ ├── OauthAuthorizationST.java
│ │ │ │ │ ├── OauthPasswordGrantsST.java
│ │ │ │ │ ├── OauthPlainST.java
│ │ │ │ │ ├── OauthScopeST.java
│ │ │ │ │ └── OauthTlsST.java
│ │ │ │ ├── OpaIntegrationST.java
│ │ │ │ ├── PodSecurityProfilesST.java
│ │ │ │ └── SecurityST.java
│ │ │ ├── specific
│ │ │ │ ├── DrainCleanerST.java
│ │ │ │ ├── HelmChartST.java
│ │ │ │ ├── RackAwarenessST.java
│ │ │ │ └── SpecificST.java
│ │ │ ├── tracing
│ │ │ │ └── OpenTelemetryST.java
│ │ │ ├── upgrade
│ │ │ │ ├── AbstractUpgradeST.java
│ │ │ │ ├── kraft
│ │ │ │ │ ├── AbstractKRaftUpgradeST.java
│ │ │ │ │ ├── KRaftKafkaUpgradeDowngradeST.java
│ │ │ │ │ ├── KRaftStrimziDowngradeST.java
│ │ │ │ │ └── KRaftStrimziUpgradeST.java
│ │ │ │ └── regular
│ │ │ │ ├── KafkaUpgradeDowngradeST.java
│ │ │ │ ├── OlmUpgradeST.java
│ │ │ │ ├── StrimziDowngradeST.java
│ │ │ │ └── StrimziUpgradeST.java
│ │ │ ├── utils
│ │ │ │ └── KafkaVersionUtilsTest.java
│ │ │ └── watcher
│ │ │ ├── AbstractNamespaceST.java
│ │ │ ├── AllNamespaceST.java
│ │ │ └── MultipleNamespaceST.java
│ │ └── resources
│ │ ├── connect-build
│ │ │ ├── build-connect-image.sh
│ │ │ └── Dockerfile
│ │ ├── junit-platform.properties
│ │ ├── META-INF
│ │ │ └── services
│ │ │ └── org.junit.platform.launcher.TestExecutionListener
│ │ ├── oauth2
│ │ │ ├── authorization_realm.json
│ │ │ ├── internal_realm.json
│ │ │ ├── keycloak-instance.yaml
│ │ │ ├── postgres.yaml
│ │ │ ├── prepare_keycloak_operator.sh
│ │ │ ├── scope_audience_realm.json
│ │ │ └── teardown_keycloak_operator.sh
│ │ ├── opa
│ │ │ └── opa.yaml
│ │ ├── security-st-certs
│ │ │ ├── clients-ca.key
│ │ │ ├── cluster-ca.key
│ │ │ ├── expired-clients-ca.crt
│ │ │ └── expired-cluster-ca.crt
│ │ ├── tracing
│ │ │ ├── cert-manager.yaml
│ │ │ ├── jaeger-instance.yaml
│ │ │ └── jaeger-operator.yaml
│ │ └── upgrade
│ │ ├── BundleDowngrade.yaml
│ │ ├── BundleUpgrade.yaml
│ │ └── OlmUpgrade.yaml
│ └── tmt
│ ├── plans
│ │ └── main.fmf
│ ├── README.md
│ ├── scripts
│ │ └── copy-logs.sh
│ └── tests
│ └── strimzi
│ ├── main.fmf
│ └── test.sh
├── test
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── io
│ └── strimzi
│ └── test
│ ├── annotations
│ │ ├── IsolatedTest.java
│ │ ├── ParallelSuite.java
│ │ └── ParallelTest.java
│ ├── EmbeddedZooKeeper.java
│ ├── executor
│ │ ├── Exec.java
│ │ └── ExecResult.java
│ ├── interfaces
│ │ ├── ExtensionContextParameterResolver.java
│ │ └── TestSeparator.java
│ ├── k8s
│ │ ├── cluster
│ │ │ ├── Kind.java
│ │ │ ├── KubeCluster.java
│ │ │ ├── Kubernetes.java
│ │ │ ├── Microshift.java
│ │ │ ├── Minikube.java
│ │ │ └── OpenShift.java
│ │ ├── cmdClient
│ │ │ ├── BaseCmdKubeClient.java
│ │ │ ├── KubeCmdClient.java
│ │ │ ├── Kubectl.java
│ │ │ └── Oc.java
│ │ ├── exceptions
│ │ │ ├── KubeClusterException.java
│ │ │ └── NoClusterException.java
│ │ ├── HelmClient.java
│ │ ├── KubeClient.java
│ │ └── KubeClusterResource.java
│ ├── logs
│ │ └── CollectorElement.java
│ ├── TestUtils.java
│ └── WaitException.java
├── tools
│ ├── git-hooks
│ │ ├── checkstyle-pre-commit
│ │ └── signoff-warning-commit-msg
│ ├── kafka-versions-tools.sh
│ ├── multi-platform-support.sh
│ ├── prerequisites-check.sh
│ ├── report.sh
│ └── strimzi-oauth-version.sh
├── topic-operator
│ ├── design
│ │ ├── cluster.png
│ │ ├── lookup.png
│ │ └── topic-store.md
│ ├── Makefile
│ ├── pom.xml
│ ├── scripts
│ │ ├── tls_prepare_certificates.sh
│ │ └── topic_operator_run.sh
│ └── src
│ ├── main
│ │ ├── java
│ │ │ └── io
│ │ │ └── strimzi
│ │ │ └── operator
│ │ │ └── topic
│ │ │ ├── Config.java
│ │ │ ├── ConflictingChangesException.java
│ │ │ ├── InvalidTopicException.java
│ │ │ ├── K8sImpl.java
│ │ │ ├── K8s.java
│ │ │ ├── K8sTopicWatcher.java
│ │ │ ├── KafkaImpl.java
│ │ │ ├── Kafka.java
│ │ │ ├── KafkaStreamsTopicStore.java
│ │ │ ├── KafkaStreamsTopicStoreService.java
│ │ │ ├── Labels.java
│ │ │ ├── LocalStoreAndServiceFactory.java
│ │ │ ├── LogContext.java
│ │ │ ├── Main.java
│ │ │ ├── OperatorException.java
│ │ │ ├── PartitionDecreaseException.java
│ │ │ ├── ReplicationFactorChangeException.java
│ │ │ ├── ResourceName.java
│ │ │ ├── Session.java
│ │ │ ├── StoreAndServiceFactory.java
│ │ │ ├── TempZkTopicStore.java
│ │ │ ├── TopicCommand.java
│ │ │ ├── TopicCommandSerde.java
│ │ │ ├── TopicConfigsWatcher.java
│ │ │ ├── TopicDiff.java
│ │ │ ├── Topic.java
│ │ │ ├── TopicMetadataHandler.java
│ │ │ ├── TopicMetadata.java
│ │ │ ├── TopicName.java
│ │ │ ├── TopicOperator.java
│ │ │ ├── TopicOperatorState.java
│ │ │ ├── TopicSerde.java
│ │ │ ├── TopicSerialization.java
│ │ │ ├── TopicStore.java
│ │ │ ├── TopicStoreTopologyProvider.java
│ │ │ ├── v2
│ │ │ │ ├── BatchingLoop.java
│ │ │ │ ├── BatchingTopicController.java
│ │ │ │ ├── DESIGN.md
│ │ │ │ ├── Either.java
│ │ │ │ ├── KubeRef.java
│ │ │ │ ├── metrics
│ │ │ │ │ ├── CustomTimerFilter.java
│ │ │ │ │ ├── TopicOperatorMetricsHolder.java
│ │ │ │ │ └── TopicOperatorMetricsProvider.java
│ │ │ │ ├── ReconcilableTopic.java
│ │ │ │ ├── TopicEvent.java
│ │ │ │ ├── TopicOperatorConfig.java
│ │ │ │ ├── TopicOperatorEventHandler.java
│ │ │ │ ├── TopicOperatorException.java
│ │ │ │ ├── TopicOperatorMain.java
│ │ │ │ └── UncheckedInterruptedException.java
│ │ │ ├── WaitForResultService.java
│ │ │ ├── zk
│ │ │ │ ├── AclBuilder.java
│ │ │ │ ├── ZkImpl.java
│ │ │ │ └── Zk.java
│ │ │ ├── Zk2KafkaStreams.java
│ │ │ ├── ZkTopicStore.java
│ │ │ ├── ZkTopicsWatcher.java
│ │ │ ├── ZkTopicWatcher.java
│ │ │ └── ZkWatcher.java
│ │ └── resources
│ │ └── log4j2.properties
│ └── test
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ └── operator
│ │ └── topic
│ │ ├── ConfigTest.java
│ │ ├── K8sImplTest.java
│ │ ├── KafkaImplTest.java
│ │ ├── KafkaStreamsTopicStoreIT.java
│ │ ├── LabelsTest.java
│ │ ├── MockK8s.java
│ │ ├── MockKafka.java
│ │ ├── MockTopicOperator.java
│ │ ├── MockTopicStore.java
│ │ ├── MockZk.java
│ │ ├── SessionStartupDoesNotBlockMainThreadTest.java
│ │ ├── SessionTest.java
│ │ ├── TopicBuilderTest.java
│ │ ├── TopicDiffTest.java
│ │ ├── TopicNameTest.java
│ │ ├── TopicOperatorBaseIT.java
│ │ ├── TopicOperatorIT.java
│ │ ├── TopicOperatorMockIT.java
│ │ ├── TopicOperatorReplicationIT.java
│ │ ├── TopicOperatorTest.java
│ │ ├── TopicOperatorTopicDeletionDisabledIT.java
│ │ ├── TopicSerializationTest.java
│ │ ├── TopicStoreTestBase.java
│ │ ├── TopicStoreUpgradeIT.java
│ │ ├── Utils.java
│ │ ├── v2
│ │ │ ├── BatchingTopicControllerTest.java
│ │ │ ├── EitherTest.java
│ │ │ ├── LogCaptor.java
│ │ │ ├── LogCaptorTest.java
│ │ │ ├── TopicControllerIT.java
│ │ │ ├── TopicOperatorConfigTest.java
│ │ │ ├── TopicOperatorMetricsTest.java
│ │ │ ├── TopicOperatorTestUtil.java
│ │ │ └── TopicUpsertTest.java
│ │ ├── zk
│ │ │ └── ZkImplTest.java
│ │ ├── ZkTopicStoreTest.java
│ │ └── ZkTopicsWatcherTest.java
│ ├── resources
│ │ ├── log4j2-test.properties
│ │ └── TopicOperatorIT-rbac.yaml
│ └── scripts
│ └── reassign.sh
├── tracing-agent
│ ├── Makefile
│ ├── pom.xml
│ └── src
│ └── main
│ └── java
│ └── io
│ └── strimzi
│ └── tracing
│ └── agent
│ ├── OpenTelemetryTracing.java
│ ├── TracingAgent.java
│ └── Tracing.java
└── user-operator
├── Makefile
├── pom.xml
├── scripts
│ └── user_operator_run.sh
└── src
├── main
│ ├── java
│ │ └── io
│ │ └── strimzi
│ │ └── operator
│ │ └── user
│ │ ├── DESIGN.md
│ │ ├── Main.java
│ │ ├── model
│ │ │ ├── acl
│ │ │ │ ├── SimpleAclRule.java
│ │ │ │ ├── SimpleAclRuleResource.java
│ │ │ │ └── SimpleAclRuleResourceType.java
│ │ │ ├── InvalidCertificateException.java
│ │ │ ├── KafkaUserModel.java
│ │ │ └── QuotaUtils.java
│ │ ├── operator
│ │ │ ├── AdminApiOperator.java
│ │ │ ├── batching
│ │ │ │ ├── AbstractBatchReconciler.java
│ │ │ │ ├── AddAclsBatchReconciler.java
│ │ │ │ ├── DeleteAclsBatchReconciler.java
│ │ │ │ ├── DESIGN.md
│ │ │ │ ├── QuotasBatchReconciler.java
│ │ │ │ └── ScramShaCredentialsBatchReconciler.java
│ │ │ ├── cache
│ │ │ │ ├── AbstractCache.java
│ │ │ │ ├── AclCache.java
│ │ │ │ ├── DESIGN.md
│ │ │ │ ├── QuotasCache.java
│ │ │ │ └── ScramShaCredentialsCache.java
│ │ │ ├── DisabledSimpleAclOperator.java
│ │ │ ├── KafkaUserOperator.java
│ │ │ ├── QuotasOperator.java
│ │ │ ├── ScramCredentialsOperator.java
│ │ │ └── SimpleAclOperator.java
│ │ ├── UserController.java
│ │ ├── UserControllerLoop.java
│ │ ├── UserControllerUtils.java
│ │ └── UserOperatorConfig.java
│ └── resources
│ └── log4j2.properties
└── test
├── java
│ └── io
│ └── strimzi
│ └── operator
│ └── user
│ ├── model
│ │ ├── acl
│ │ │ ├── SimpleAclRuleResourceTest.java
│ │ │ └── SimpleAclRuleTest.java
│ │ ├── KafkaUserModelCertificateHandlingTest.java
│ │ └── KafkaUserModelTest.java
│ ├── operator
│ │ ├── AdminApiOperatorIT.java
│ │ ├── batching
│ │ │ ├── AbstractBatchReconcilerTest.java
│ │ │ ├── AddAclsBatchReconcilerTest.java
│ │ │ ├── DeleteAclsBatchReconcilerTest.java
│ │ │ ├── QuotasBatchReconcilerTest.java
│ │ │ └── ScramShaCredentialsBatchReconcilerTest.java
│ │ ├── cache
│ │ │ ├── AbstractCacheTest.java
│ │ │ ├── AclCacheTest.java
│ │ │ ├── QuotasCacheTest.java
│ │ │ └── ScramShaCredentialsCacheTest.java
│ │ ├── KafkaUserOperatorMockTest.java
│ │ ├── QuotasOperatorIT.java
│ │ ├── ScramCredentialsOperatorIT.java
│ │ ├── SimpleAclOperatorIT.java
│ │ └── SimpleAclOperatorTest.java
│ ├── ResourceUtils.java
│ ├── UserControllerMockTest.java
│ └── UserOperatorConfigTest.java
└── resources
└── log4j2-test.properties
585 directories, 2503 files
标签: Kubernetes Apache kafka NET PAC
小贴士
感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论