AtlasStreamConnection Recurso personalizado

Exemplos

Os exemplos a seguir adicionam uma conexão ao Registro de conexões do espaço de trabalho de processamento de fluxo. Para saber mais, consulte Gerenciar o Atlas Stream Processing.

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

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

Parâmetros

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 sistema Apache Kafka. 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 sistema Apache Kafka. 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 sistema Apache Kafka. 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 sistema Apache Kafka. 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.