El recurso personalizado AtlasStreamConnection configura
Atlas Stream Processing conexiones. Puedes configurar una conexión de muestra, una conexión a un flujo de cambios de Atlas o una conexión a un 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 conexión de flujo
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 | Consulta la documentación de Kubernetes | true |
| Objeto |
| false |
| Objeto |
| false |
AtlasStreamConnection.spec
AtlasStreamConnectionSpec define el estado objetivo de AtlasStreamConnection.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Etiqueta legible por humanos que identifica de manera única la conexión de streaming. | true |
| enum | Tipo de conexión. Puede ser tanto clúster como Kafka. Enum: Kafka, clúster, muestra | true |
| Objeto | La configuración que se utilizará para conectarse a un clúster de Atlas. | false |
| Objeto | La configuración que se utilizará para conectarse a un clúster de Kafka. | false |
AtlasStreamConnection.spec.clusterConfig
La configuración que se utilizará para conectarse a un clúster de 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.rol
El nombre de un rol integrado o de un rol personalizado de base de datos para conectarse a un clúster Atlas.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | El | true |
| enum | Tipo del rol | true |
AtlasStreamConnection.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 requeridas para conectarse a un Clúster de Kafka. Incluye el tipo | true |
| string | Lista separada por comas de direcciones de servidor | true |
| Objeto | Propiedades para la conexión de transporte segura con Kafka. Para | true |
| map[string]string | Un mapa de pares clave-valor de Kafka para la configuración opcional. Este es un objeto plano y las claves pueden tener caracteres '.'. | false |
AtlasStreamConnection.especificacion.ConfiguracionKafka.autenticación
Credenciales de usuario requeridas para conectarse a un Clúster de Kafka. Incluye el tipo de autenticación, así como los parámetros para ese modo de autenticación.
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 ser uno de | true |
AtlasStreamConnection.spec.kafkaConfig.autenticación.credenciales
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 | namespace del recurso de Kubernetes | false |
AtlasStreamConnection.spec.kafkaConfig.seguridad
Propiedades para la conexión de transporte segura a Kafka. Para SSL, esto puede incluir el certificado confiable que se debe usar.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| enum | Describe el tipo de transporte. Puede ser | true |
| Objeto | Un x509 | false |
AtlasStreamConnection.spec.kafkaConfig.seguridad.certificate
Un certificado público x509 confiable para conectarse a Kafka a través de SSL.
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Nombre del recurso de Kubernetes | true |
| string | namespace del recurso de Kubernetes | false |
AtlasStreamConnection.status
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 Atlas | true |
| []objeto | Lista de | false |
| entero |
| false |
AtlasStreamConnection.status.conditions
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 recursos personalizados de Atlas. | true |
| string | La última vez, la condición pasó de un estado a otro. Representado en formato | false |
| string | Un | false |
| string | El | false |
AtlasStreamConnection.status.instances
ResourceRefNamespaced es una referencia a un recurso de Kubernetes que permite configurar el namespace
Name | Tipo | Descripción | Requerido |
|---|---|---|---|
| string | Nombre del recurso de Kubernetes | true |
| string | namespace del recurso de Kubernetes | false |