El recurso personalizado AtlasStreamConnection configura
Atlas Stream Processing Conexiones. Puede configurar una conexión de muestra, una conexión a un flujo de cambios de Atlas o una conexión a Apache Kafka. sistema.
Ejemplos
Los siguientes ejemplos añaden una conexión para agregar a la Registro de Conexiones del espacio de trabajo de stream processing. Para aprender más, consulta Administrar Atlas Stream Processing.
Conexión de muestra
apiVersion: atlas.mongodb.com/v1 kind: AtlasStreamConnection metadata: name: my-stream-connection spec: name: sample_stream_solar type: Sample
Nota
Si usted especifica Sample para el parámetro spec.type, el parámetro spec.name debe coincidir con el nombre de la colección de muestra. Actualmente, Atlas Kubernetes Operator solo es compatible con la colección de muestra sample_stream_solar para este recurso personalizado.
Cambiar la conexión de transmisión
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
Conexión 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
Parámetros
AtlasStreamConnection
AtlasStreamConnection es el esquema para la API de atlasstreamconnections
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | atlas.mongodb.com/v1 | true |
| string |
| true |
| Objeto | Consulte la documentación de Kubernetes | true |
| Objeto |
| false |
| Objeto |
| false |
Conexión AtlasStream.spec
AtlasStreamConnectionSpec define el estado de destino de AtlasStreamConnection.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Etiqueta legible por humanos que identifica de forma única la conexión de transmisión. | true |
| enum | Tipo de conexión. Puede ser de clúster o de Kafka. Enumeración: Kafka, clúster, muestra. | true |
| Objeto | La configuración que se utilizará para conectarse a un clúster Atlas. | false |
| Objeto | La configuración que se utilizará para conectarse a un clúster de Kafka. | false |
Conexión de AtlasStream.spec.clusterConfig
La configuración que se utilizará para conectarse a un clúster Atlas.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Nombre del clúster configurado para esta conexión. | true |
| Objeto | El nombre de un rol | true |
AtlasStreamConnection.spec.clusterConfig.role
El nombre de una función de base de datos personalizada o integrada para conectarse a un clúster Atlas.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | El | true |
| enum | Tipo del | true |
Conexión AtlasStream.spec.kafkaConfig
La configuración que se utilizará para conectarse a un clúster de Kafka.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| Objeto | Credenciales de usuario necesarias para conectarse a un clúster de Kafka. Incluye el tipo | true |
| string | Lista de direcciones de servidores separadas por comas | true |
| Objeto | Propiedades para la conexión de transporte segura a Kafka. Para | true |
| mapa[cadena]cadena | Un mapa de pares clave-valor de Kafka para configuración opcional. Este es un objeto plano y las claves pueden tener caracteres ".". | false |
AtlasStreamConnection.spec.kafkaConfig.autenticación
Credenciales de usuario necesarias para conectarse a un clúster de Kafka. Incluye el tipo de autenticación y sus parámetros.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| Objeto | Referencia al secreto que contiene el nombre de usuario y la contraseña de la cuenta para conectar con el clúster de Kafka. | true |
| enum | Estilo de autenticación. Puede | true |
AtlasStreamConnection.spec.kafkaConfig.authentication.credentials
Referencia al secreto que contiene el nombre de usuario y la contraseña de la cuenta para conectar con el clúster de Kafka.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Nombre del recurso de Kubernetes | true |
| string | Espacio de nombres del recurso de Kubernetes | false |
Conexión AtlasStream.spec.kafkaConfig.security
Propiedades para la conexión de transporte segura a Kafka. Para SSL, esto puede incluir el certificado de confianza que se utilizará.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| enum | Describe el tipo de transporte. Puede ser | true |
| Objeto | Un x509 | false |
AtlasStreamConnection.spec.kafkaConfig.security.certificate
Un certificado x509 público y confiable para conectarse a Kafka a través de SSL.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Nombre del recurso de Kubernetes | true |
| string | Espacio de nombres del recurso de Kubernetes | false |
Estado de la conexión AtlasStream
AtlasStreamConnectionStatus define el estado observado de AtlasStreamConnection.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| []objeto | Condiciones es la lista de estados que muestra el estado actual del recurso personalizado de Atlas | true |
| []objeto | Lista de | false |
| entero |
| false |
Condiciones de estado de AtlasStreamConnection
La condición describe el estado de un recurso personalizado de Atlas en un momento determinado.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Estado de la condición; uno de Verdadero, Falso, Desconocido. | true |
| string | Tipo de condición de recurso personalizado de Atlas. | true |
| string | Última vez que la condición cambió de un estado a otro. Representado en | false |
| string | A | false |
| string | El | false |
AtlasStreamConnection.status.instances
ResourceRefNamespaced es una referencia a un recurso de Kubernetes que permite configurar el espacio de nombres
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Nombre del recurso de Kubernetes | true |
| string | Espacio de nombres del recurso de Kubernetes | false |