Menu Docs
Página inicial do Docs
/ /
Kubernetes Operator do MongoDB Atlas
/

AtlasStreamConnection Recurso personalizado

Nesta página

  • Exemplos
  • Conexão de amostra
  • Alterar conexão do stream
  • Conexão Kafka
  • Parâmetros

O AtlasStreamConnection recurso personalizado configura conexões Atlas Stream Processing . Você pode configurar uma conexão de amostra, uma conexão com um fluxo de alterações do Atlas ou uma conexão com um Apache Kafka sistema.

Os exemplos seguintes adicionam uma conexão para adicionar ao Registro de Conexões da instância de Atlas Stream Processing . Para saber mais, consulte Gerenciar Atlas Stream Processing.

apiVersion: atlas.mongodb.com/v1
kind: AtlasStreamConnection
metadata:
name: my-stream-connection
spec:
name: sample_stream_solar
type: Sample

Observação

Se você especificar Sample para o parâmetro spec.type , o parâmetro spec.name deverá corresponder ao nome da collection de amostra. Atualmente, o Atlas Kubernetes Operator suporta somente a collection de amostra 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 seção descreve os parâmetros do AtlasStreamConnection disponíveis.

spec.name

Tipo: string

Obrigatório

Nome que identifica a conexão do Atlas Stream Processing .

Observação

Se você especificar Sample para o parâmetro spec.type , o parâmetro spec.name deverá corresponder ao nome da collection de amostra. Atualmente, o Atlas Kubernetes Operator suporta somente a collection de amostra sample_stream_solar para este recurso personalizado.

spec.type

Tipo: string

Obrigatório

string que indica o tipo de conexão. Os valores válidos incluem:

  • Sample

  • Cluster

  • Kafka

spec.clusterConfig

Tipo: objeto

Condicional

Objeto que contém a configuração da conexão com um change stream do Atlas . Se você especificou Cluster para o parâmetro spec.type , deverá especificar esta configuração.

spec.clusterConfig.name

Tipo: string

Condicional

Nome que identifica a conexão com o Atlas change stream. Se você especificou Cluster para o parâmetro spec.type , deverá especificar esta configuração.

spec.clusterConfig.role

Tipo: string

Condicional

Função de banco de dados para a conexão com o change stream do Atlas. Se você especificou Cluster para o parâmetro spec.type , deverá especificar esta configuração.

spec.clusterConfig.role.name

Tipo: string

Condicional

Nome que identifica a função de banco de dados para a conexão com o fluxo de alteração do Atlas. Se você especificou Cluster para o parâmetro spec.type , deverá especificar esta configuração.

spec.clusterConfig.role.type

Tipo: string

Condicional

string que indica o tipo de papel do banco de dados. Os valores válidos incluem:

  • BUILT_IN

  • CUSTOM

Para saber mais, consulte Configurar funções personalizadas do banco de dados.

spec.kafkaConfig

Tipo: objeto

Condicional

Objeto que contém a configuração da conexão com um Apache Kafka sistema. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.bootstrapServers

Tipo: array

Condicional

Lista separada por vírgulas de endereços de servidor para a conexão com um Apache Kafka sistema. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.authentication

Tipo: objeto

Condicional

Objeto que contém a configuração do mecanismo de autenticação e credenciais. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.authentication.mechanism

Tipo: string

Condicional

string que indica o mecanismo de autenticação para a conexão com um Apache Kafka sistema. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração. Os valores válidos incluem:

  • PLAIN

  • SCRAM-256

  • SCRAM-512

spec.kafkaConfig.authentication.credentials

Tipo: objeto

Condicional

Objeto que contém a referência ao segredo que contém as credenciais de autenticação. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.authentication.credentials.name

Tipo: string

Condicional

Nome do segredo opaco que contém suas credenciais de autenticação. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.authentication.credentials.namespace

Tipo: string

Condicional

Namespace do segredo opaco que contém suas credenciais de autenticação. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.security

Tipo: objeto

Condicional

Objeto que contém a configuração do protocolo de segurança e certificado. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.security.protocol

Tipo: string

Condicional

string que indica o protocolo de segurança para a conexão com um Apache Kafka sistema. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração. Os valores válidos incluem:

  • PLAIN

  • SSL

spec.kafkaConfig.security.certificate

Tipo: objeto

Condicional

Objeto que contém a configuração do certificado de segurança. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.security.certificate.name

Tipo: string

Condicional

Nome do segredo opaco que contém seu certificado de segurança. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

spec.kafkaConfig.security.certificate.namespace

Tipo: string

Condicional

Namespace do segredo opaco que contém seu certificado de segurança. Se você especificou Kafka para o parâmetro spec.type , deverá especificar esta configuração.

Voltar

AtlasSearchIndexConfig