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 a seguir adicionam uma conexão ao Registro de conexões do espaço de trabalho de stream processing. Para saber mais, veja 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
AtlasStreamConnection
AtlasStreamConnection é o esquema para a API atlasstreamconnections
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | atlas.mongodb.com/v1 | true |
| string |
| true |
| objeto | Consulte a documentação do Kubernetes | true |
| objeto |
| false |
| objeto |
| false |
AtlasStreamConnection.spec
AtlasStreamConnectionSpec define o estado de destino do AtlasStreamConnection.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | Etiqueta legível por humanos que identifica exclusivamente a conexão do stream. | true |
| enum | Tipo de conexão. Pode ser cluster ou Kafka. Enum: Kafka, Cluster, Sample | true |
| objeto | A configuração a ser utilizada para conectar a um Atlas Cluster. | false |
| objeto | A configuração a ser usada para se conectar a um Kafka Cluster. | false |
AtlasStreamConnection.spec.clusterConfig
A configuração a ser utilizada para conectar a um Atlas Cluster.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | Nome do cluster configurado para esta conexão. | true |
| objeto | O nome de um role | true |
AtlasStreamConnection.spec.clusterConfig.role
O nome de um role de banco de dados integrado ou personalizado para conectar-se a um cluster Atlas .
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | O | true |
| enum | Tipo da | true |
AtlasStreamConnection.spec.kafkaConfig
A configuração a ser usada para se conectar a um Kafka Cluster.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| objeto | Credenciais de usuário necessárias para se conectar a um Kafka Cluster. Inclui o tipo | true |
| string | Lista separada por vírgula de endereços de servidor | true |
| objeto | Propriedades para a conexão de transporte segura com o Kafka. Para | true |
| map[string]string | Um mapa de pares de valores-chave Kafka para configuração opcional. Este é um objeto plano e as chaves podem ter '.' caracteres. | false |
AtlasStreamConnection.spec.kafkaConfig.authentication
Credenciais de usuário necessárias para se conectar a um Kafka Cluster. Inclui o tipo de autenticação, bem como os parâmetros para esse modo de autenticação.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| objeto | Referência ao segredo que contém o nome de usuário e a senha da conta para se conectar ao Kafka cluster. | true |
| enum | Estilo de autenticação. Pode ser um | true |
AtlasStreamConnection.spec.kafkaConfig.authentication.credentials
Referência ao segredo que contém o nome de usuário e a senha da conta para se conectar ao Kafka cluster.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | Nome do Recurso Kubernetes | true |
| string | Namespace do Recurso Kubernetes | false |
AtlasStreamConnection.spec.kafkaConfig.security
Propriedades para a conexão de transporte segura com o Kafka. Para SSL, isso pode incluir o certificado confiável a ser usado.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| enum | Descreve o tipo de transporte. Pode ser ou. | true |
| objeto | Um x509 | false |
AtlasStreamConnection.spec.kafkaConfig.security.certificate
Um certificado x509 público e confiável para conexão com o Kafka por SSL.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | Nome do Recurso Kubernetes | true |
| string | Namespace do Recurso Kubernetes | false |
AtlasStreamConnection.status
AtlasStreamConnectionStatus define o estado observado de AtlasStreamConnection.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| [] objeto | Condições é a lista de status que mostra o estado atual do Recurso Personalizado do Atlas | true |
| [] objeto | Lista de | false |
| inteiro |
| false |
AtlasStreamConnection.status. conditions
A condição descreve o estado de um recurso personalizado do Atlas em um determinado ponto.
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | Status da condição; um de verdadeiro, falso, desconhecido. | true |
| string | Tipo de condição do Atlas Custom Resource. | true |
| string | Última vez que a condição fez a transição de um status para outro. Representado no | false |
| string | Um | false |
| string | O | false |
AtlasStreamConnection.status.instances
ResourceRefNamespaced é uma referência a um Recurso do Kubernetes que permite configurar o namespace
Name | Tipo | Descrição | Obrigatório |
|---|---|---|---|
| string | Nome do Recurso Kubernetes | true |
| string | Namespace do Recurso Kubernetes | false |