主页
产品
Streams for Apache Kafka
2.6
AMQ Streams API 参考
第 69 章 KafkaConnectSpec 模式参考

第 69 章 KafkaConnectSpec 模式参考

used in: KafkaConnect

KafkaConnectSpec 模式属性的完整列表

配置 Kafka Connect 集群。

69.1. config
复制链接

使用 config 属性将 Kafka Connect 选项配置为密钥。

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

字符串
Number
布尔值

某些选项具有默认值：

group.id 带有默认值 connect-cluster
带有默认值 connect-cluster-offsets 的 offset.storage.topic
config.storage.topic 带有默认值 connect-cluster-configs
status.storage.topic 带有默认值 connect-cluster-status
key.converter 带有默认值 org.apache.kafka.connect.json.JsonConverter
value.converter，默认值为 org.apache.kafka.connect.json.JsonConverter

如果 KafkaConnect.spec.config 属性中不存在这些选项，则这些选项会被自动配置。

例外

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

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

Kafka 集群 bootstrap 地址
安全性（加密、身份验证和授权）
侦听器和 REST 接口配置
插件路径配置

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

bootstrap.servers
consumer.interceptor.classes
监听器.
plugin.path
producer.interceptor.classes
REST。
SASL。
安全性。
ssl.

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

支持的 TLS 版本和密码套件的任何 ssl 配置

Kafka Connect 配置示例

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
  name: my-connect
spec:
  # ...
  config:
    group.id: my-connect-cluster
    offset.storage.topic: my-connect-cluster-offsets
    config.storage.topic: my-connect-cluster-configs
    status.storage.topic: my-connect-cluster-status
    key.converter: org.apache.kafka.connect.json.JsonConverter
    value.converter: org.apache.kafka.connect.json.JsonConverter
    key.converter.schemas.enable: true
    value.converter.schemas.enable: true
    config.storage.replication.factor: 3
    offset.storage.replication.factor: 3
    status.storage.replication.factor: 3
  # ...

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
  name: my-connect
spec:
  # ...
  config:
    group.id: my-connect-cluster
    offset.storage.topic: my-connect-cluster-offsets
    config.storage.topic: my-connect-cluster-configs
    status.storage.topic: my-connect-cluster-status
    key.converter: org.apache.kafka.connect.json.JsonConverter
    value.converter: org.apache.kafka.connect.json.JsonConverter
    key.converter.schemas.enable: true
    value.converter.schemas.enable: true
    config.storage.replication.factor: 3
    offset.storage.replication.factor: 3
    status.storage.replication.factor: 3
  # ...

Copy to Clipboard

Toggle word wrap

重要

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

返回顶部

第 69 章 KafkaConnectSpec 模式参考

69.1. config
复制链接

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

第 69 章 KafkaConnectSpec 模式参考

69.1. config复制链接链接已复制到粘贴板!

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

69.1. config
复制链接