O AtlasStreamConnection recurso personalizado configura conexões Atlas Stream Processing. Você pode configurar uma conexão de amostra, uma conexão com um change stream do Atlas ou uma conexão com um sistema Apache Kafka.
Exemplos
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.
Conexão de amostra
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.
Alterar conexão do stream
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
Conexão 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 seção descreve os parâmetros do AtlasStreamConnection disponíveis.
spec.nameTipo: string
Obrigatório
Nome que identifica a conexão do Atlas Stream Processing .
Observação
Se você especificar
Samplepara o parâmetrospec.type, o parâmetrospec.namedeverá corresponder ao nome da collection de amostra. Atualmente, o Atlas Kubernetes Operator suporta somente a collection de amostrasample_stream_solarpara este recurso personalizado.spec.typeTipo: string
Obrigatório
string que indica o tipo de conexão. Os valores válidos incluem:
SampleClusterKafka
spec.clusterConfigTipo: objeto
Condicional
Objeto que contém a configuração da conexão com um change stream do Atlas . Se você especificou
Clusterpara o parâmetrospec.type, deverá especificar esta configuração.spec.clusterConfig.nameTipo: string
Condicional
Nome que identifica a conexão com o Atlas change stream. Se você especificou
Clusterpara o parâmetrospec.type, deverá especificar esta configuração.spec.clusterConfig.roleTipo: string
Condicional
Função de banco de dados para a conexão com o change stream do Atlas. Se você especificou
Clusterpara o parâmetrospec.type, deverá especificar esta configuração.spec.clusterConfig.role.nameTipo: 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
Clusterpara o parâmetrospec.type, deverá especificar esta configuração.spec.clusterConfig.role.typeTipo: string
Condicional
string que indica o tipo de papel do banco de dados. Os valores válidos incluem:
BUILT_INCUSTOM
Para saber mais, consulte Configurar funções personalizadas do banco de dados.
spec.kafkaConfigTipo: objeto
Condicional
Objeto que contém a configuração da conexão com um sistema Apache Kafka. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.bootstrapServersTipo: array
Condicional
Lista separada por vírgulas de endereços de servidor para a conexão com um sistema Apache Kafka. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.authenticationTipo: objeto
Condicional
Objeto que contém a configuração do mecanismo de autenticação e credenciais. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.authentication.mechanismTipo: string
Condicional
string que indica o mecanismo de autenticação para a conexão com um sistema Apache Kafka. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração. Os valores válidos incluem:PLAINSCRAM-256SCRAM-512
spec.kafkaConfig.authentication.credentialsTipo: objeto
Condicional
Objeto que contém a referência ao segredo que contém as credenciais de autenticação. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.authentication.credentials.nameTipo: string
Condicional
Nome do segredo opaco que contém suas credenciais de autenticação. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.authentication.credentials.namespaceTipo: string
Condicional
Namespace do segredo opaco que contém suas credenciais de autenticação. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.securityTipo: objeto
Condicional
Objeto que contém a configuração do protocolo de segurança e certificado. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.security.protocolTipo: string
Condicional
string que indica o protocolo de segurança para a conexão com um sistema Apache Kafka. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração. Os valores válidos incluem:PLAINSSL
spec.kafkaConfig.security.certificateTipo: objeto
Condicional
Objeto que contém a configuração do certificado de segurança. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.security.certificate.nameTipo: string
Condicional
Nome do segredo opaco que contém seu certificado de segurança. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.spec.kafkaConfig.security.certificate.namespaceTipo: string
Condicional
Namespace do segredo opaco que contém seu certificado de segurança. Se você especificou
Kafkapara o parâmetrospec.type, deverá especificar esta configuração.