B.116.3. config
使用 consumer.config
属性为消费者配置 Kafka 选项。
config
属性包含 Kafka MirrorMaker consumer 配置选项作为键,其值以以下 JSON 类型之一的形式设置:
- 字符串
- 数字
- 布尔值
对于使用特定 密码套件 作为 TLS 版本进行客户端连接,您可以配置 allowed ssl
属性。您还可以 配置 ssl.endpoint.identification.algorithm 属性来
启用或禁用主机名验证。
例外
您可以为消费者指定并配置 Apache Kafka 配置文档 中列出的选项。
但是,与以下相关的 AMQ Streams 会自动配置和管理的选项会有例外:
- Kafka 集群 bootstrap 地址
- 安全(加密、身份验证和授权)
- 消费者组标识符
- 拦截器
具体来说,所有键为等于或以以下任一字符串开头的配置选项将被禁止:
-
bootstrap.servers
-
group.id
-
interceptor.classes
-
SSL.
(不包括特定例外) -
SASL.
-
安全性.
当 config
属性中存在禁止选项时,会忽略它,并把警告信息输出到 Cluster Operator 日志文件中。所有其他选项都传递给 Kafka MirrorMaker。
Cluster Operator 不会验证提供的 config
对象中的密钥或值。当提供无效的配置时,Kafka MirrorMaker 可能无法启动或可能变得不稳定。在这种情况下,Kafka MirrorMaker.spec.consumer.config
对象中的配置应该被修复,Cluster Operator 将推出 Kafka MirrorMaker 的新配置。