Join us at MongoDB.local London on 7 May to unlock new possibilities for your data. Use WEB50 to save 50%.
Register now >
Docs Menu
Docs Home
/ /
/ / /

AtlasStreamConnection Recurso personalizado

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.

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.

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.

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
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

Esta sección describe los parámetros AtlasStreamConnection disponibles.

spec.name

Tipo: string

Requerido

Nombre que identifica la conexión de procesamiento de flujo.

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.

spec.type

Tipo: string

Requerido

Cadena que indica el tipo de conexión. Los valores válidos son:

  • Sample

  • Cluster

  • Kafka

spec.clusterConfig

Tipo: objeto

Condicional

Objeto que contiene la configuración de la conexión a un flujo de cambiosen Atlas. Si ha especificado Cluster para el parámetro spec.type, debe especificar esta configuración.

spec.clusterConfig.name

Tipo: string

Condicional

Nombre que identifica la conexión al flujo de cambios de Atlas. Si especificaste Cluster para el parámetro spec.type, debes especificar esta configuración.

spec.clusterConfig.role

Tipo: string

Condicional

Rol de base de datos para la conexión al flujo de cambios de Atlas. Si especificaste Cluster para el parámetro spec.type, debes especificar esta configuración.

spec.clusterConfig.role.name

Tipo: string

Condicional

Nombre que identifica el rol de base de datos para la conexión al Atlas flujo de cambios. Si ha especificado Cluster para el parámetro spec.type, debe especificar esta configuración.

spec.clusterConfig.role.type

Tipo: string

Condicional

Cadena que indica el tipo de rol de la base de datos. Los valores válidos son:

  • BUILT_IN

  • CUSTOM

Para obtener más información,consulte Configurar roles de base de datos personalizados.

spec.kafkaConfig

Tipo: objeto

Condicional

Objeto que contiene la configuración para la conexión a un sistema Apache Kafka. Si especificaste Kafka para el parámetro spec.type, debes especificar esta configuración.

spec.kafkaConfig.bootstrapServers

Tipo: arreglo

Condicional

Lista separada por comas de direcciones de servidores para la conexión a un sistema Apache Kafka. Si especificaste Kafka para el parámetro spec.type, debes especificar esta configuración.

spec.kafkaConfig.authentication

Tipo: objeto

Condicional

Objeto que contiene la configuración para el mecanismo de autenticación y las credenciales. Si especificas Kafka para el parámetro spec.type, debes especificar esta configuración.

spec.kafkaConfig.authentication.mechanism

Tipo: string

Condicional

Cadena que indica el mecanismo de autenticación para la conexión a un sistema Apache Kafka. Si especificó Kafka para el spec.type parámetro, debe especificar esta configuración. Los valores válidos son:

  • PLAIN

  • SCRAM-256

  • SCRAM-512

spec.kafkaConfig.authentication.credentials

Tipo: objeto

Condicional

Objeto que contiene la referencia a secreto que contiene las credenciales de autenticación. Si especificaste Kafka para el parámetro spec.type, debes especificar esta configuración.

spec.kafkaConfig.authentication.credentials.name

Tipo: string

Condicional

Nombre del secreto opaco que contiene tus credenciales de autenticación. Si especificaste Kafka para el parámetro spec.type, debes especificar esta configuración.

spec.kafkaConfig.authentication.credentials.namespace

Tipo: string

Condicional

Namespace del secreto opaco que contiene tus credenciales de autenticación. Si especificaste Kafka para el parámetro spec.type, debes especificar esta configuración.

spec.kafkaConfig.security

Tipo: objeto

Condicional

Objeto que contiene la configuración del protocolo de seguridad y el certificado. Si especificó Kafka para el parámetro spec.type, debe especificar esta configuración.

spec.kafkaConfig.security.protocol

Tipo: string

Condicional

string que indica el protocolo de seguridad para la conexión a un sistema Apache Kafka. Si especificaste Kafka para el parámetro spec.type, debes especificar esta configuración. Los valores válidos incluyen:

  • PLAIN

  • SSL

spec.kafkaConfig.security.certificate

Tipo: objeto

Condicional

Objeto que contiene la configuración del certificado de seguridad. Si especificó Kafka para el parámetro spec.type, debe especificar esta configuración.

spec.kafkaConfig.security.certificate.name

Tipo: string

Condicional

Nombre del secreto opaco que contiene su certificado de seguridad. Si especificó Kafka para el spec.type parámetro, debe especificar esta configuración.

spec.kafkaConfig.security.certificate.namespace

Tipo: string

Condicional

Espacio de nombres del secreto opaco que contiene su certificado de seguridad. Si especificó Kafka para el spec.type parámetro, debe especificar esta configuración.

Volver

AtlasSearchIndexConfig

En esta página