El AtlasStreamConnection recurso personalizado 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
Esta sección describe los parámetros AtlasStreamConnection disponibles.
spec.nameTipo: string
Requerido
Nombre que identifica la conexión de procesamiento de flujo.
Nota
Si usted especifica
Samplepara el parámetrospec.type, el parámetrospec.namedebe coincidir con el nombre de la colección de muestra. Actualmente, Atlas Kubernetes Operator solo es compatible con la colección de muestrasample_stream_solarpara este recurso personalizado.spec.typeTipo: string
Requerido
Cadena que indica el tipo de conexión. Los valores válidos son:
SampleClusterKafka
spec.clusterConfigTipo: objeto
Condicional
Objeto que contiene la configuración de la conexión a un flujo de cambiosen Atlas. Si ha especificado
Clusterpara el parámetrospec.type, debe especificar esta configuración.spec.clusterConfig.nameTipo: string
Condicional
Nombre que identifica la conexión al flujo de cambios de Atlas. Si especificó
Clusterpara elspec.typeparámetro, debe especificar esta configuración.spec.clusterConfig.roleTipo: string
Condicional
Rol de base de datos para la conexión al flujo de cambios de Atlas. Si especificó
Clusterpara elspec.typeparámetro, debe especificar esta configuración.spec.clusterConfig.role.nameTipo: string
Condicional
Nombre que identifica el rol de base de datos para la conexión al Atlas flujo de cambios. Si ha especificado
Clusterpara el parámetrospec.type, debe especificar esta configuración.spec.clusterConfig.role.typeTipo: string
Condicional
Cadena que indica el tipo de rol de la base de datos. Los valores válidos son:
BUILT_INCUSTOM
Para obtener más información,consulte Configurar roles de base de datos personalizados.
spec.kafkaConfigTipo: objeto
Condicional
Objeto que contiene la configuración para la conexión a un sistema Apache Kafka. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración.spec.kafkaConfig.bootstrapServersTipo: arreglo
Condicional
Lista de direcciones de servidor separadas por comas para la conexión a un sistema Apache Kafka. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración.spec.kafkaConfig.authenticationTipo: objeto
Condicional
Objeto que contiene la configuración del mecanismo de autenticación y las credenciales. Si especificó
Kafkapara el parámetrospec.type, debe especificar esta configuración.spec.kafkaConfig.authentication.mechanismTipo: string
Condicional
Cadena que indica el mecanismo de autenticación para la conexión a un sistema Apache Kafka. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración. Los valores válidos son:PLAINSCRAM-256SCRAM-512
spec.kafkaConfig.authentication.credentialsTipo: objeto
Condicional
Objeto que contiene la referencia al secreto que contiene las credenciales de autenticación. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración.spec.kafkaConfig.authentication.credentials.nameTipo: string
Condicional
Nombre del secreto opaco que contiene sus credenciales de autenticación. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración.spec.kafkaConfig.authentication.credentials.namespaceTipo: string
Condicional
Espacio de nombres del secreto opaco que contiene sus credenciales de autenticación. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración.spec.kafkaConfig.securityTipo: objeto
Condicional
Objeto que contiene la configuración del protocolo de seguridad y el certificado. Si especificó
Kafkapara el parámetrospec.type, debe especificar esta configuración.spec.kafkaConfig.security.protocolTipo: string
Condicional
Cadena que indica el protocolo de seguridad para la conexión a un sistema Apache Kafka. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración. Los valores válidos son:PLAINSSL
spec.kafkaConfig.security.certificateTipo: objeto
Condicional
Objeto que contiene la configuración del certificado de seguridad. Si especificó
Kafkapara el parámetrospec.type, debe especificar esta configuración.spec.kafkaConfig.security.certificate.nameTipo: string
Condicional
Nombre del secreto opaco que contiene su certificado de seguridad. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración.spec.kafkaConfig.security.certificate.namespaceTipo: string
Condicional
Espacio de nombres del secreto opaco que contiene su certificado de seguridad. Si especificó
Kafkapara elspec.typeparámetro, debe especificar esta configuración.