第 71 章 KafkaConnectSpec 模式参考
used in: KafkaConnect
配置 Kafka Connect 集群。
71.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 文档 中列出的选项。
但是，Apache Kafka 的流负责配置和管理与以下内容相关的选项，而这无法更改：
- Kafka 集群 bootstrap 地址
- 安全性（加密、身份验证和授权）
- 侦听器和 REST 接口配置
- 插件路径配置
无法设置具有以下前缀的属性：
-
bootstrap.servers -
consumer.interceptor.classes -
监听器. -
plugin.path -
producer.interceptor.classes -
REST。 -
SASL。 -
安全性。 -
ssl.
如果 config 属性包含一个无法更改的选项，它将被忽略，并将警告信息记录到 Cluster Operator 日志文件。所有其他支持选项都转发到 Kafka Connect，包括对流为 Apache Kafka 配置的选项的以下例外：
-
支持的 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
# ...
重要
Cluster Operator 不会密钥或 config 对象中提供的值。如果提供了无效的配置，Kafka Connect 集群可能无法启动，或者可能会不稳定。在这种情况下，修复配置，以便 Cluster Operator 可将新配置部署到所有 Kafka Connect 节点。
