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
Kafka 接続
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
型: オブジェクト
条件付き
Atlas変更ストリームへの接続の構成を含むオブジェクト。
spec.type
パラメータにCluster
を指定した場合は、この設定を指定する必要があります。spec.clusterConfig.name
型: string
条件付き
Atlas変更ストリームへの接続を識別する名前。
spec.type
パラメータにCluster
を指定した場合は、この設定を指定する必要があります。spec.clusterConfig.role
型: string
条件付き
Atlas Change Streamへの接続用データベース ロール。
spec.type
パラメータにCluster
を指定した場合は、この設定を指定する必要があります。spec.clusterConfig.role.name
型: string
条件付き
Atlas変更ストリームへの接続のデータベース ロールを識別する名前。
spec.type
パラメータにCluster
を指定した場合は、この設定を指定する必要があります。spec.clusterConfig.role.type
型: string
条件付き
データベース ロールのタイプを示すstring 。 有効な値は以下のとおりです。
BUILT_IN
CUSTOM
詳細については、「カスタム データベース ロールの構成 」を参照してください。
spec.kafkaConfig
型: オブジェクト
条件付き
Apache Kafkaシステムへの接続の構成を含むオブジェクト。 パラメータに
Kafka
spec.type
を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.bootstrapServers
タイプ: 配列
条件付き
Apache Kafkaシステムへの接続用のサーバーアドレスのコンマ区切りリスト。
Kafka
パラメータにspec.type
を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.authentication
型: オブジェクト
条件付き
認証メカニズムと認証情報の構成を含むオブジェクト。
spec.type
パラメータにKafka
を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.authentication.mechanism
型: string
条件付き
Apache Kafkaシステムへの接続の認証メカニズムを示す string。
Kafka
パラメータにspec.type
を指定した場合は、この設定を指定する必要があります。有効な値は以下のとおりです。PLAIN
SCRAM-256
SCRAM-512
spec.kafkaConfig.authentication.credentials
型: オブジェクト
条件付き
認証資格情報を含むシークレットへの参照を含むオブジェクト。
Kafka
spec.type
パラメータに を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.authentication.credentials.name
型: string
条件付き
認証資格情報を含むオペレーターのシークレットの名前。
Kafka
spec.type
パラメータに を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.authentication.credentials.namespace
型: string
条件付き
認証情報を含むオペレーターのシークレットの名前空間。
Kafka
spec.type
パラメータに を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.security
型: オブジェクト
条件付き
セキュリティ プロトコルと証明書の構成を含むオブジェクト。
spec.type
パラメータにKafka
を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.security.protocol
型: string
条件付き
Apache Kafkaシステムへの接続のセキュリティプロトコルを示す string。
Kafka
パラメータにspec.type
を指定した場合は、この設定を指定する必要があります。有効な値は以下のとおりです。PLAIN
SSL
spec.kafkaConfig.security.certificate
型: オブジェクト
条件付き
セキュリティ証明書の構成を含むオブジェクト。
spec.type
パラメータにKafka
を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.security.certificate.name
型: string
条件付き
秘密証明書を含む opaque secret の名前。 パラメータに
Kafka
spec.type
を指定した場合は、この設定を指定する必要があります。spec.kafkaConfig.security.certificate.namespace
型: string
条件付き
セキュリティ証明書を含むオペレーターのシークレットの名前空間。 パラメータに
Kafka
spec.type
を指定した場合は、この設定を指定する必要があります。