在好例子网,分享、交流、成长!
您当前所在位置:首页Others 开发实例一般编程问题 → strimzi-kafka-operator:在Kubernetes上运行Apache Kafka®

strimzi-kafka-operator:在Kubernetes上运行Apache Kafka®

一般编程问题

下载此实例

实例介绍

【实例简介】
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

网友评论

发表评论

(您的评论需要经过审核才能显示)

查看所有0条评论>>

小贴士

感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。

  • 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
  • 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
  • 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
  • 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。

关于好例子网

本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明

;
报警