AI エージェント向け: ドキュメントインデックスは https://www.mongodb.com/ja-jp/docs/llms.txt で利用できます。すべてのページの markdown バージョンは、いずれかの URL パスに .md を追加することで利用できます。
Docs Menu

AtlasStreamConnection カスタム リソース

AtlasStreamConnection カスタムリソースはAtlas Stream Processing 接続 を構成します。サンプル接続、Atlas変更ストリームへの接続、またはApache Kafkaシステムへの接続を構成できます。

次の例では、ストリーム処理ワークスペースの接続レジストリに追加する接続を追加します。詳細については、Atlas Stream Processing を管理するをご覧ください。

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

注意

spec.typeパラメータにSampleを指定する場合、 spec.nameパラメータはサンプル コレクション名と一致する必要があります。 現在、Atlas Kubernetes Operator は、このカスタム リソースのsample_stream_solarサンプル コレクションのみをサポートしています。

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

型: string

必須

Atlas Stream Processing 接続を識別する名前。

注意

spec.typeパラメータにSampleを指定する場合、 spec.nameパラメータはサンプル コレクション名と一致する必要があります。 現在、Atlas Kubernetes Operator は、このカスタム リソースのsample_stream_solarサンプル コレクションのみをサポートしています。

spec.type

型: string

必須

接続のタイプを示す string。 有効な値は以下のとおりです。

  • Sample

  • Cluster

  • Kafka

spec.clusterConfig

型: オブジェクト

条件付き

Object that contains the configuration for the connection to an Atlas change stream. If you specified Cluster for the spec.type parameter, you must specify this setting.

spec.clusterConfig.name

型: string

条件付き

Name that identifies the connection to the Atlas change stream. If you specified Cluster for the spec.type parameter, you must specify this setting.

spec.clusterConfig.role

型: string

条件付き

Database role for the connection to the Atlas change stream. If you specified Cluster for the spec.type parameter, you must specify this setting.

spec.clusterConfig.role.name

型: string

条件付き

Name that identifies the database role for the connection to the Atlas change stream. If you specified Cluster for the spec.type parameter, you must specify this setting.

spec.clusterConfig.role.type

型: string

条件付き

データベース ロールのタイプを示すstring 。 有効な値は以下のとおりです。

  • BUILT_IN

  • CUSTOM

To learn more, see Configure Custom Database Roles.

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

条件付き

Apache Kafkaシステムへの接続の認証メカニズムを示す string。spec.type パラメータに Kafka を指定した場合は、この設定を指定する必要があります。有効な値は以下のとおりです。

  • PLAIN

  • SCRAM-256

  • SCRAM-512

spec.kafkaConfig.authentication.credentials

型: オブジェクト

条件付き

認証資格情報を含むシークレットへの参照を含むオブジェクト。spec.type パラメータに Kafka を指定した場合は、この設定を指定する必要があります。

spec.kafkaConfig.authentication.credentials.name

型: string

条件付き

認証資格情報を含むオペレーターのシークレットの名前。spec.type パラメータに Kafka を指定した場合は、この設定を指定する必要があります。

spec.kafkaConfig.authentication.credentials.namespace

型: string

条件付き

認証情報を含むオペレーターのシークレットの名前空間。spec.type パラメータに Kafka を指定した場合は、この設定を指定する必要があります。

spec.kafkaConfig.security

型: オブジェクト

条件付き

セキュリティ プロトコルと証明書の構成を含むオブジェクト。 spec.typeパラメータにKafkaを指定した場合は、この設定を指定する必要があります。

spec.kafkaConfig.security.protocol

型: string

条件付き

Apache Kafkaシステムへの接続のセキュリティプロトコルを示す string。spec.type パラメータに Kafka を指定した場合は、この設定を指定する必要があります。有効な値は以下のとおりです。

  • PLAIN

  • SSL

spec.kafkaConfig.security.certificate

型: オブジェクト

条件付き

セキュリティ証明書の構成を含むオブジェクト。 spec.typeパラメータにKafkaを指定した場合は、この設定を指定する必要があります。

spec.kafkaConfig.security.certificate.name

型: string

条件付き

秘密証明書を含む opaque secret の名前。spec.type パラメータに Kafka を指定した場合は、この設定を指定する必要があります。

spec.kafkaConfig.security.certificate.namespace

型: string

条件付き

セキュリティ証明書を含むオペレーターのシークレットの名前空間。spec.type パラメータに Kafka を指定した場合は、この設定を指定する必要があります。