AtlasStreamConnection
Recurso personalizado
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.
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.name
Tipo: string
Obrigatório
Nome que identifica a conexão do Atlas Stream Processing .
Observação
Se você especificar
Sample
para o parâmetrospec.type
, o parâmetrospec.name
deverá corresponder ao nome da collection de amostra. Atualmente, o Atlas Kubernetes Operator suporta somente a collection de amostrasample_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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.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âmetrospec.type
, deverá especificar esta configuração.