The 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。 有効な値は以下のとおりです。
SampleClusterKafka
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_INCUSTOM
詳細については、「カスタム データベース ロールの構成 」を参照してください。
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を指定した場合は、この設定を指定する必要があります。有効な値は以下のとおりです。PLAINSCRAM-256SCRAM-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を指定した場合は、この設定を指定する必要があります。有効な値は以下のとおりです。PLAINSSL
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を指定した場合は、この設定を指定する必要があります。