B.118.2. config
使用 producer.config
属性为制作者配置 Kafka 选项。
config
属性包含 Kafka MirrorMaker producer 配置选项作为键,其值在以下 JSON 类型之一中设置:
- 字符串
- 数字
- 布尔值
对于使用特定 密码套件 作为 TLS 版本进行客户端连接,您可以配置 allowed ssl
属性。您还可以 配置 ssl.endpoint.identification.algorithm 属性来
启用或禁用主机名验证。
例外
您可以为生产者指定并配置 Apache Kafka 配置文档 中列出的选项。
但是,与以下相关的 AMQ Streams 会自动配置和管理的选项会有例外:
- Kafka 集群 bootstrap 地址
- 安全(加密、身份验证和授权)
- 拦截器
具体来说,所有键为等于或以以下任一字符串开头的配置选项将被禁止:
-
bootstrap.servers
-
interceptor.classes
-
SSL.
(不包括特定例外) -
SASL.
-
安全性.
当 config
属性中存在禁止选项时,会忽略它,并把警告信息输出到 Cluster Operator 日志文件中。所有其他选项都传递给 Kafka MirrorMaker。
Cluster Operator 不会验证提供的 config
对象中的密钥或值。当提供无效的配置时,Kafka MirrorMaker 可能无法启动或可能变得不稳定。在这种情况下,Kafka MirrorMaker.spec.producer.config
对象中的配置应该被修复,Cluster Operator 将推出 Kafka MirrorMaker 的新配置。
属性 | 描述 |
---|---|
bootstrapServers | 用于建立与 Kafka 集群的初始连接的 host:port 对列表。 |
字符串 | |
abortOnSendFailure |
将 MirrorMaker 设置为在失败发送时退出的标记。默认值为 |
布尔值 | |
身份验证 |
用于连接到集群的身份验证配置。这个类型取决于给定对象中的 |
| |
config | MirrorMaker 制作者配置.无法设置带有以下前缀的属性: ssl.、bootstrap.servers、sasl.、security.、拦截器.classes(ssl.endpoint.identification.algorithm、ssl.cipher.suites、ssl.protocols、ssl.protocols.protocols 除外)。 |
map | |
tls | 将 MirrorMaker 连接到集群的 TLS 配置。 |