AtlasStreamConnection 自定义资源

示例

以下示例将一个连接添加到Atlas Stream Processing实例的连接注册表中。 要了解更多信息，请参阅管理 Atlas Stream Processing。

apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamConnection
metadata:
  name: my-stream-connection
spec:
  name: sample_stream_solar
type: Sample

apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamConnection
metadata:
  name: my-stream-connection
spec:
  name: my-stream-connection
  type: Cluster
  clusterConfig:
    name: my-cluster
    role:
      name: my-db-role
      type: CUSTOM

apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamConnection
metadata:
  name: my-stream-connection
spec:
  name: my-stream-connection
  type: Kafka
  kafkaConfig:
    bootstrapServers: "comma,separated,list,of,server,addresses"
    authentication:
      mechanism: SCRAM-512
      credentials:
        name: ref-to-creds-secret
        namespace: default
    security:
      protocol: SSL
      certificate:
        name: ref-to-certificate-secret
        namespace: default

参数

本部分介绍可用的AtlasStreamConnection参数。

spec.name

类型：字符串

必需

标识Atlas Stream Processing连接的名称。

注意

如果您为spec.type参数指定Sample ，则spec.name参数必须与样本集合名称匹配。 目前，Atlas Kubernetes Operator 仅支持此自定义资源的sample_stream_solar样本集合。

spec.type

类型：字符串

必需

指示连接类型的string 。 有效值包括：

• Sample

• Cluster

• Kafka

spec.clusterConfig

类型：对象

可选的

包含连接到 Atlas变更流的配置的对象。 如果您为spec.type参数指定了Cluster ，则必须指定此设置。

spec.clusterConfig.name

类型：字符串

可选的

标识与 Atlas变更流的连接的名称。 如果您为spec.type参数指定了Cluster ，则必须指定此设置。

spec.clusterConfig.role

类型：字符串

可选的

用于连接到 Atlas变更流的数据库角色。 如果您为spec.type参数指定了Cluster ，则必须指定此设置。

spec.clusterConfig.role.name

类型：字符串

可选的

用于标识连接到 Atlas变更流的数据库角色的名称。 如果您为spec.type参数指定了Cluster ，则必须指定此设置。

spec.clusterConfig.role.type

类型：字符串

可选的

string ，表示数据库角色的类型。 有效值包括：

• BUILT_IN

• CUSTOM

要了解更多信息，请参阅配置自定义数据库角色。

spec.kafkaConfig

类型：对象

可选的

包含连接到 Apache Kafka 的配置的对象 系统。如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.bootstrapServers

类型：数组

可选的

以逗号分隔的服务器地址列表，用于连接到 Apache Kafka 系统。如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.authentication

类型：对象

可选的

包含身份验证机制和档案配置的对象。 如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.authentication.mechanism

类型：字符串

可选的

string，表示连接到 的身份验证机制ApacheKafka 系统。如果您为spec.type参数指定了Kafka ，则必须指定此设置。 有效值包括：

• PLAIN

• SCRAM-256

• SCRAM-512

spec.kafkaConfig.authentication.credentials

类型：对象

可选的

包含对 密钥 引用的对象 包含身份验证凭证。如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.authentication.credentials.name

类型：字符串

可选的

不透明 密钥 的名称 包含您的身份验证档案。如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.authentication.credentials.namespace

类型：字符串

可选的

不透明 密钥 的命名空间 包含您的身份验证档案。如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.security

类型：对象

可选的

包含安全协议和证书配置的对象。 如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.security.protocol

类型：字符串

可选的

string，表示连接到 的安全协议ApacheKafka 系统。如果您为spec.type参数指定了Kafka ，则必须指定此设置。 有效值包括：

• PLAIN

• SSL

spec.kafkaConfig.security.certificate

类型：对象

可选的

包含安全证书配置的对象。 如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.security.certificate.name

类型：字符串

可选的

不透明 密钥 的名称 包含您的安全证书。如果您为spec.type参数指定了Kafka ，则必须指定此设置。

spec.kafkaConfig.security.certificate.namespace

类型：字符串

可选的

不透明 密钥 的命名空间 包含您的安全证书。如果您为spec.type参数指定了Kafka ，则必须指定此设置。