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 的新配置。

Expand

属性	描述
bootstrapServers	用于建立与 Kafka 集群的初始连接的 host:port 对列表。
字符串	用于建立与 Kafka 集群的初始连接的 host:port 对列表。
abortOnSendFailure	将 MirrorMaker 设置为在失败发送时退出的标记。默认值为 `true`。
布尔值	将 MirrorMaker 设置为在失败发送时退出的标记。默认值为 `true`。
身份验证	用于连接到集群的身份验证配置。这个类型取决于给定对象中的 `authentication.type` 属性的值，必须是 [tls, scram-sha-512, plain, oauth] 中的一个。
`KafkaClientAuthenticationTls`, `KafkaClientAuthenticationScramSha512`, `KafkaClientAuthenticationPlain`, `KafkaClientAuthenticationOAuth`
config	MirrorMaker 制作者配置.无法设置带有以下前缀的属性： ssl.、bootstrap.servers、sasl.、security.、拦截器.classes（ssl.endpoint.identification.algorithm、ssl.cipher.suites、ssl.protocols、ssl.protocols.protocols 除外）。
map
tls	将 MirrorMaker 连接到集群的 TLS 配置。
`KafkaMirrorMakerTls`	将 MirrorMaker 连接到集群的 TLS 配置。

返回顶部

B.118.2. config

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links