Docs Menu
Docs Home
/ /
Recursos personalizados
/ / /

AtlasStreamConnection Recurso personalizado

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.

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 especificó Cluster para el spec.type parámetro, debe 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 especificó Cluster para el spec.type parámetro, debe 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 especificó Kafka para el spec.type parámetro, debe especificar esta configuración.

spec.kafkaConfig.bootstrapServers

Tipo: arreglo

Condicional

Lista de direcciones de servidor separadas por comas para la conexión a un sistema Apache Kafka. Si especificó Kafka para el spec.type parámetro, debe especificar esta configuración.

spec.kafkaConfig.authentication

Tipo: objeto

Condicional

Objeto que contiene la configuración del mecanismo de autenticación y las credenciales. Si especificó Kafka para el parámetro spec.type, debe 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 al secreto que contiene las credenciales de autenticación. Si especificó Kafka para el spec.type parámetro, debe especificar esta configuración.

spec.kafkaConfig.authentication.credentials.name

Tipo: string

Condicional

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

spec.kafkaConfig.authentication.credentials.namespace

Tipo: string

Condicional

Espacio de nombres del secreto opaco que contiene sus credenciales de autenticación. Si especificó Kafka para el spec.type parámetro, debe 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

Cadena que indica el protocolo de seguridad 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

  • 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