117.3. config


使用 consumer.config 属性将消费者的 Kafka 选项配置为密钥。

这些值可以是以下 JSON 类型之一:

  • 字符串
  • Number
  • 布尔值

例外

您可以为用户指定并配置 Apache Kafka 配置文档中列出的选项

但是,AMQ Streams 会负责配置和管理与以下内容相关的选项,这无法更改:

  • Kafka 集群 bootstrap 地址
  • 安全性(加密、身份验证和授权)
  • 消费者组标识符
  • 拦截器

无法设置具有以下前缀的属性:

  • bootstrap.servers
  • group.id
  • interceptor.classes
  • sasl.
  • 安全性。
  • ssl.

如果 config 属性包含无法更改的选项,它将被忽略,并会记录一条警告消息到 Cluster Operator 日志文件。所有其他支持选项都转发到 MirrorMaker,包括以下例外到 AMQ Streams 配置的选项:

重要

Cluster Operator 不会密钥或 config 对象中提供的值。如果提供了无效的配置,则 MirrorMaker 集群可能无法启动或不稳定。在这种情况下,修复配置,以便 Cluster Operator 可将新配置部署到所有 MirrorMaker 节点。

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.