120.3. config
使用 consumer.config
属性将消费者的 Kafka 选项配置为密钥。
这些值可以是以下 JSON 类型之一:
- 字符串
- Number
- 布尔值
例外
您可以为用户指定并配置 Apache Kafka 配置文档中列出的选项。
但是,Apache Kafka 的流负责配置和管理与以下内容相关的选项,而这无法更改:
- Kafka 集群 bootstrap 地址
- 安全性(加密、身份验证和授权)
- 消费者组标识符
- 拦截器
无法设置具有以下前缀的属性:
-
bootstrap.servers
-
group.id
-
interceptor.classes
-
SASL。
-
安全性。
-
ssl.
如果 config
属性包含一个无法更改的选项,它将被忽略,并将警告信息记录到 Cluster Operator 日志文件。所有其他支持选项都转发到 MirrorMaker,包括对 Apache Kafka 的 Streams 配置的选项的以下例外:
-
支持的 TLS 版本和密码套件的任何
ssl
配置
重要
Cluster Operator 不会密钥或 config
对象中提供的值。如果提供了无效的配置,MirrorMaker 集群可能无法启动,或者可能不稳定。在这种情况下,修复配置,以便 Cluster Operator 可将新配置部署到所有 MirrorMaker 节点。