O AtlasStreamConnection recurso personalizado configura as conexões do 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. enumeração: Kafka, cluster, amostra | 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 uma função | true |
AtlasStreamConnection.spec.clusterConfig.função
O nome de uma função 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 função | 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.autenticação
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 dos | true |
AtlasStreamConnection.spec.kafkaConfig.autenticação.credenciais
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.segurança
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 | true |
| objeto | Um x509 | false |
AtlasStreamConnection.spec.kafkaConfig.segurança.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 recurso. | true |
| string | Última vez que a condição fez a transição de um status para outro. Representado no formato | false |
| string | Um | false |
| string | O | false |
AtlasStreamConnection.status.instâncias
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 |