Estabelecer Conexão com o Confluent Kafka
Aprenda a criar uma conexão com o Confluent Kafka, que você usa com a conexão Confluent Schema Registry, para servir como origem ou destino em uma implantação do OCI GoldenGate Big Data.
Antes de começar
Antes de criar a conexão, certifique-se de:
- Verifique como o OCI GoldenGate se conecta à sua origem e aos seus destinos.
- Configure as políticas necessárias para permitir o acesso seguro ao Vault e aos Segredos, como usar segredos, usar vaults e ler pacotes de segredos. Para obter mais informações, consulte Políticas mínimas recomendadas.
Criar uma conexão de origem
Para criar uma conexão do Confluent Kafka de origem:
A conexão aparece na lista Conexões, na qual você pode selecioná-la para exibir seus detalhes. Certifique-se de criar também uma conexão com o Confluent Schema Registry e designe ambas as conexões a uma implantação do Big Data.
Criar uma conexão de destino
Para criar uma conexão do Confluent Kafka de destino:
A conexão aparece na lista Conexões, na qual você pode selecioná-la para exibir seus detalhes. Certifique-se de criar também uma conexão com o Confluent Schema Registry e designe ambas as conexões a uma implantação do Big Data.
Crie uma conexão com o Confluent Cloud com Links Privados
O Link Privado permite que você acesse seu cluster do Confluent Cloud em execução em uma nuvem de terceiros por meio de um ponto final privado que existe em sua rede virtual.
Antes de criar a conexão, certifique-se de que você tem o seguinte:
- Crie conectividade de rede privada entre o OCI (Oracle Cloud Infrastructure) e a nuvem de terceiros de destino.
- Ao adicionar configuração de rede para link privado no Confluent Cloud, certifique-se de selecionar Resolução de DNS Privado.
- Configure zonas de DNS e configure registros de DNS na nuvem de terceiros onde você configurou o Confluent Cloud e no OCI. No OCI, você pode criar zonas dentro das views privadas da sua VCN. Em zonas, você pode adicionar os registros de DNS necessários.
Você pode usar as instruções acima para criar a conexão, mas no lugar das Etapas 5 e 6, faça o seguinte:
- Para a Etapa 3e:
- Forneça os detalhes da porta e do host dos servidores de Inicialização.
- Você pode adicionar vários servidores Bootstrap.
- Para 3f:
- Para o protocolo de Segurança, selecione SASL sobre Texto Sem Formatação.
- Informe o nome do usuário e a senha.
Solucionar problemas de erros de conexão do Kafka
A maioria dos problemas de conexão resulta em erros TimeoutException. Por exemplo:
A failure occurred sending a message to Kafka to topic [ggstest] org.apache.kafka.common.errors.TimeoutException: Topic ggstest not present in metadata after 60000/120000 ms.
Se você encontrar essa mensagem no arquivo de relatório Replicat, poderá:
- Certifique-se de que o tópico de destino esteja presente ou verifique se a criação automática de tópico está ativada nas definições do Kafka de destino.
- Certifique-se de que não haja regras de firewall bloqueando o tráfego.
- Se você estiver executando o Kafka no OCI com um ponto final privado, certifique-se de usar o FQDN Interno como o servidor de bootstrap em server.properties e na conexão do Kafka.
- Se você estiver se conectando a uma Nuvem Confluente com pontos finais privados:
- Certifique-se de que as zonas de DNS e os registros de DNS estejam configurados corretamente no OCI e na nuvem de terceiros de destino.
- Certifique-se de que a conexão de rede entre o OCI e a nuvem de destino funcione bem.
- Teste se você pode estabelecer conexão com o Confluent Cloud de destino com OpenSSL (
openssl s_client -connect <bootstrap>
) de uma VM do OCI em execução na mesma sub-rede conectada à nuvem de terceiros. - Teste se você pode publicar ou consumir mensagens de um cliente Kafka em execução no OCI dentro da mesma sub-rede conectada à nuvem de terceiros. Se ele falhar, verifique suas definições de rede no OCI e na nuvem de terceiros.