76.2. KafkaConnectSpec 模式属性

version

string

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

replicas

整数

Kafka Connect 组中的 pod 数量。默认值为 3。

image

string

用于 Kafka Connect pod 的容器镜像。如果没有明确指定镜像名称，它会根据 spec.version 配置决定。镜像名称被专门映射到 Cluster Operator 配置中的对应版本。

bootstrapServers

string

要连接的引导服务器。这应该以逗号分隔的 < hostname> :_< port>_ 对列表提供。

tls

clientTLS

TLS 配置。

身份验证

KafkaClientAuthenticationTls, KafkaClientAuthenticationScramSha256, KafkaClientAuthenticationScramSha512, KafkaClientAuthenticationPlain, KafkaClientAuthenticationOAuth

Kafka Connect 的身份验证配置。

config

map

Kafka Connect 配置。无法设置带有以下前缀的属性： ssl., sasl., security., listener, plugin.path, rest., bootstrap.servers, consumer.interceptor.classes, producer.interceptor.classes （例外： ssl.endpoint.identification.algorithm, ssl.cipher.suites, ssl.protocol, ssl.enabled.protocols）。

resources

ResourceRequirements

CPU 和内存资源和请求的初始资源的最大限制。

livenessProbe

probe

Pod 存活度检查。

readinessProbe

probe

Pod 就绪度检查。

jvmOptions

JvmOptions

pod 的 JVM 选项。

jmxOptions

KafkaJmxOptions

JMX 选项.

logging

InlineLogging, ExternalLogging

Kafka Connect 的日志记录配置。

clientRackInitImage

string

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

rack

Rack

配置用作 client.rack 消费者配置的节点标签。

metricsConfig

JmxPrometheusExporterMetrics

指标配置。

tracing

jaegertracing, OpenTelemetryTracing

在 Kafka Connect 中配置追踪。

模板

KafkaConnectTemplate

Kafka Connect 和 Kafka MirrorMaker 2 资源的模板。该模板允许用户指定如何生成 Pod、Service 和其他服务。

externalConfiguration

externalConfiguration

将来自 Secret 或 ConfigMap 的数据传递给 Kafka Connect pod，并使用它们配置连接器。

build

build

配置如何构建 Connect 容器镜像。可选。