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
AtlasStreamConnection は、 atlasstream connection APIのスキーマです
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | atlas.mongodb.com/v1 | true |
| string |
| true |
| オブジェクト |
| true |
| オブジェクト |
| false |
| オブジェクト |
| false |
AtlasStreamConnection.spec
AtlasStreamConnectionSpec は、AtlasStreamConnection のターゲット状態を定義します。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | ストリーム接続を一意に識別する、人間に判読可能なラベル。 | true |
| 列挙 | 接続のタイプ。クラスター またはKafka のいずれかになります。列挙: Kafka、クラスター、サンプル | true |
| オブジェクト | Atlas クラスターに接続するために使用する構成。 | false |
| オブジェクト | Kafkaクラスターに接続するために使用する構成。 | false |
AtlasStreamConnection.spec.clusterConfig
Atlas クラスターに接続するために使用する構成。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | この接続用に構成されたクラスターの名前。 | true |
| オブジェクト | Atlas クラスタに接続するための組み込みまたはカスタム | true |
AtlasStreamConnection.spec.clusterConfig.role
Atlasクラスタに接続するための組み込みまたはカスタム DB ロールの名前。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | 使用するロールの | true |
| 列挙 |
| true |
AtlasStreamConnection.spec.kafkaConfig
Kafkaクラスターに接続するために使用する構成。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| オブジェクト | Kafkaクラスターに接続するために必要なユーザー認証情報。 | true |
| string | サーバーアドレスのカンマ区切りリスト | true |
| オブジェクト | Kafkaへの安全なトランスポート接続のプロパティ。 | true |
| map[string]string | 任意構成用のKafka のキーと値のペアのマップ。これは 平面オブジェクトであり、キーは「」を持つことができます。文字。 | false |
AtlasStreamConnection.spec.kafkaConfig認証
Kafkaクラスターに接続するために必要なユーザー認証情報。認証タイプと、その認証モードのパラメータが含まれます。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| オブジェクト | Kafkaクラスターに接続するためのアカウントの ユーザー名とパスワード を含むシークレットへの参照。 | true |
| 列挙 | 認証のタイプ。 | true |
AtlasStreamConnection.spec.kafkaConfig認証.credentials
Kafkaクラスターに接続するためのアカウントの ユーザー名とパスワード を含むシークレットへの参照。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | Kubernetesリソースの名前 | true |
| string | Kubernetesリソースの名前空間 | false |
AtlasStreamConnection.spec.kafkaConfig.security
Kafkaへの安全なトランスポート接続のプロパティ。 SSL の場合、使用する信頼できる証明書をこれに含めることができます。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| 列挙 | トランスポートの種類を説明します。 | true |
| オブジェクト |
| false |
AtlasStreamConnection.spec.kafkaConfig.security.certify
SSL 経由でKafkaに接続するための信頼できる公開 x509 証明書。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | Kubernetesリソースの名前 | true |
| string | Kubernetesリソースの名前空間 | false |
AtlasStreamConnection.status
AtlasStreamConnectionStatus は、AtlasStreamConnection の監視された状態を定義します。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| []オブジェクト | 条件は、Atlas カスタム リソースの現在の状態を示すステータスのリストです | true |
| []オブジェクト | 接続構成を使用する | false |
| integer |
| false |
AtlasStreamConnection.status.条件
条件 は、 特定の点における Atlas カスタム リソースの状態を表します。
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | 条件のステータス。 True、False、Unknown のいずれか 1 つ。 | true |
| string | Atlas カスタム リソース条件のタイプ。 | true |
| string | 条件があるステータスから別のステータスに最後に移行した時刻。 | false |
| string | 移行に関する詳細を提供する | false |
| string | 条件の最後の移行の | false |
AtlasStreamConnection.status.instances
ResourceRefNamespaced はKubernetesリソースへの参照であり、名前空間を構成できます
Name | タイプ | 説明 | 必須 |
|---|---|---|---|
| string | Kubernetesリソースの名前 | true |
| string | Kubernetesリソースの名前空間 | false |