5.3. KafkaClusterSpec 模式属性

version

string

Kafka 代理版本。默认为最新版本。请参阅用户文档了解升级或降级版本所需的流程。

metadataVersion

string

在 Streams for Apache Kafka 2.7 中添加。Kafka 集群使用的 KRaft 元数据版本。在 ZooKeeper 模式下运行时，会忽略此属性。如果没有设置属性，则默认为与 version 属性对应的元数据版本。

replicas

整数

集群中的 pod 数量。当节点池没有使用时，需要此属性。

image

string

用于 Kafka pod 的容器镜像。如果没有设置属性，则默认 Kafka 镜像版本会根据 版本 配置决定。镜像名称被专门映射到 Cluster Operator 配置中的对应版本。更改 Kafka 镜像版本不会自动为其他组件更新镜像版本，如 Kafka Exporter。

监听器

GenericKafkaListener 数组

配置监听程序以提供对 Kafka 代理的访问。

config

map

无法设置带有以下前缀的 Kafka 代理配置属性： listeners, advertised., broker., listener., host.name, port, inter.broker.listener.name, sasl., ssl., security., password., log.dir, zookeeper.connect, zookeeper.set.acl, zookeeper.ssl, zookeeper.clientCnxnSocket, authorizer., super.user, cruise.control.metrics.topic, cruise.control.metrics.reporter.bootstrap.servers, node.id, process.roles, controller. metadata.log.dir, zookeeper.metadata.migration.enable, client.quota.callback.static.kafka.admin., client.quota.callback.static.produce, client.quota.callback.static.fetch, client.quota.callback.static.storage.per.volume.limit.min.available., client.quota.callback.static.excluded.principal.name.list （带有 zookeeper.connection.timeout.ms, sasl.server.max.receive.size, ssl.cipher.suites, ssl.cipher.suites 除外） ssl.protocol, ssl.enabled.protocols, ssl.secure.random.implementation, cruise.control.metrics.topic.num.partitions, cruise.control.metrics.topic.replication.factor, cruise.control.metrics.topic.retention.ms, cruise.control.metrics.topic.auto.create.retries, cruise.control.metrics.topic.auto.create.timeout.ms, cruise.control.metrics.topic.min.insync.replicas, controller.quorum.election.backoff.max.ms, controller.quorum.election.timeout.ms, controller.quorum.fetch.timeout.ms）。

storage

EphemeralStorage, PersistentClaimStorage, JbodStorage

存储配置（磁盘）。无法更新。当节点池没有使用时，需要此属性。

授权

KafkaAuthorizationSimple, KafkaAuthorizationOpa, KafkaAuthorizationKeycloak, KafkaAuthorizationCustom

Kafka 代理的授权配置。

rack

Rack

配置 broker.rack 代理配置。

brokerRackInitImage

string

用于初始化 broker.rack 的 init 容器的镜像。

livenessProbe

probe

Pod 存活度检查。

readinessProbe

probe

Pod 就绪度检查。

jvmOptions

JvmOptions

pod 的 JVM 选项。

jmxOptions

KafkaJmxOptions

Kafka 代理的 JMX 选项。

resources

ResourceRequirements

要保留的 CPU 和内存资源。

metricsConfig

JmxPrometheusExporterMetrics

指标配置。

logging

InlineLogging, ExternalLogging

Kafka 的日志记录配置。

模板

KafkaClusterTemplate

Kafka 集群资源的模板。该模板允许用户指定如何生成 OpenShift 资源。

tieredStorage

TieredStorageCustom

为 Kafka 代理配置分层存储功能。

配额

QuotasPluginKafka, QuotasPluginStrimzi

Kafka 代理的配额插件配置允许设置磁盘用量配额、生成/抓取率等。支持的插件类型包括 kafka （默认）和 strimzi。如果没有指定，则使用默认 kafka 配额插件。