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 sistema Apache Kafka.
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
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
string que indica el tipo de conexión. Los valores válidos incluyen:
SampleClusterKafka
spec.clusterConfigTipo: Objeto
Condicional
Objeto que contiene la configuración para la conexión a un Atlas flujo de cambios. Si especificó
Clusterpara el parámetrospec.type, debe especificar esta configuración.spec.clusterConfig.nameTipo: string
Condicional
Nombre que identifica la conexión con Atlas flujo de cambios. Si especificó
Clusterpara el parámetrospec.type, debe especificar esta configuración.spec.clusterConfig.roleTipo: string
Condicional
Rol de base de datos para la conexión al Atlas flujo de cambios. Si especificó
Clusterpara el parámetrospec.type, debe especificar esta configuración.spec.clusterConfig.role.nameTipo: string
Condicional
Nombre que identifica el rol de la base de datos para la conexión al Atlas flujo de cambios. Si especificó
Clusterpara el parámetrospec.type, debe especificar esta configuración.spec.clusterConfig.role.typeTipo: string
Condicional
String que indica el tipo de rol de la base de datos. Los valores válidos incluyen:
BUILT_INCUSTOM
Para obtener más información, consulta Configurar roles personalizados de base de datos.
spec.kafkaConfigTipo: Objeto
Condicional
Objeto que contiene la configuración para la conexión a un sistema Apache Kafka. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.bootstrapServersTipo: arreglo
Condicional
Lista separada por comas de direcciones de servidores para la conexión a un sistema Apache Kafka. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.authenticationTipo: Objeto
Condicional
Objeto que contiene la configuración para el mecanismo de autenticación y las credenciales. Si especificas
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.authentication.mechanismTipo: string
Condicional
String que indica el mecanismo de autenticación para la conexión a un Apache Kafka sistema. Si especificó
Kafkapara el parámetrospec.type, debe especificar esta configuración. Los valores válidos incluyen:PLAINSCRAM-256SCRAM-512
spec.kafkaConfig.authentication.credentialsTipo: Objeto
Condicional
Objeto que contiene la referencia a secreto que contiene las credenciales de autenticación. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.authentication.credentials.nameTipo: string
Condicional
Nombre del secreto opaco que contiene tus credenciales de autenticación. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.authentication.credentials.namespaceTipo: string
Condicional
Namespace del secreto opaco que contiene tus credenciales de autenticación. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.securityTipo: Objeto
Condicional
Objeto que contiene la configuración para el protocolo de seguridad y el certificado. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.security.protocolTipo: string
Condicional
string que indica el protocolo de seguridad para la conexión a un sistema Apache Kafka. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración. Los valores válidos incluyen:PLAINSSL
spec.kafkaConfig.security.certificateTipo: Objeto
Condicional
Objeto que contiene la configuración del certificado de seguridad. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.security.certificate.nameTipo: string
Condicional
Nombre del secreto opaco que contiene tu certificado de seguridad. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.spec.kafkaConfig.security.certificate.namespaceTipo: string
Condicional
Namespace del secreto opaco que contiene tu certificado de seguridad. Si especificaste
Kafkapara el parámetrospec.type, debes especificar esta configuración.