第 129 章 KafkaBridgeConsumerSpec 模式参考
used in: KafkaBridgeSpec
KafkaBridgeConsumerSpec
模式属性的完整列表
将 Kafka Bridge 的消费者选项配置为密钥。
这些值可以是以下 JSON 类型之一:
- 字符串
- Number
- 布尔值
例外
您可以为用户指定并配置 Apache Kafka 配置文档中列出的选项。
但是,Apache Kafka 的流负责配置和管理与以下内容相关的选项,而这无法更改:
- Kafka 集群 bootstrap 地址
- 安全性(加密、身份验证和授权)
- 消费者组标识符
无法设置具有以下前缀的属性:
-
bootstrap.servers
-
group.id
-
SASL。
-
安全性。
-
ssl.
如果 config
属性包含一个无法更改的选项,它将被忽略,并将警告信息记录到 Cluster Operator 日志文件。所有其他支持选项都转发到 Kafka Bridge,包括对流为 Apache Kafka 配置的选项的以下例外:
-
支持的 TLS 版本和密码套件的任何
ssl
配置
Kafka Bridge 消费者配置示例
apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaBridge metadata: name: my-bridge spec: # ... consumer: config: auto.offset.reset: earliest enable.auto.commit: true # ...
Cluster Operator 不会验证 config
对象中的键或值。如果提供了无效的配置,Kafka Bridge 部署可能无法启动,或者可能会不稳定。在这种情况下,修复配置,以便 Cluster Operator 可将新配置部署到所有 Kafka Bridge 节点。
129.1. KafkaBridgeConsumerSpec
模式属性
属性 | 属性类型 | 描述 |
---|---|---|
config | map | 用于网桥创建的消费者实例的 Kafka 使用者配置。无法设置带有以下前缀的属性:ssl., bootstrap.servers, group.id, sasl., security. (除:ssl.endpoint.identification.algorithm, ssl.cipher.suites, ssl.protocol, ssl.enabled.protocols)。 |