Configuração
A configuração de conectores no Kafka Connect envolve a edição de arquivos de propriedades para cada conector específico.
Adicionando uma origem
Para instalar um conector de origem (source connector) no Kafka Connect, siga estes passos:
Baixe o conector: Primeiro, você precisa baixar o arquivo JAR do conector de origem que deseja instalar. Você pode encontrar uma lista de conectores de origem disponíveis na seção de plugins do Kafka Connect no site do Confluent Hub (https://www.confluent.io/hub/).
Coloque o arquivo JAR no diretório de plugins do Kafka Connect: Depois de baixar o arquivo JAR do conector de origem, coloque-o no diretório de plugins do Kafka Connect. O diretório padrão é
<caminho_do_kafka_connect>/plugins
.Reinicie o Kafka Connect: Após colocar o arquivo JAR no diretório de plugins, você precisa reiniciar o Kafka Connect para que ele carregue o novo conector. Certifique-se de parar e iniciar o Kafka Connect corretamente.
Configure o conector: Depois de reiniciar o Kafka Connect, você precisa configurar o conector de origem no arquivo de propriedades correspondente. Abra o arquivo de propriedades do Kafka Connect, geralmente chamado
connect-standalone.properties
para modo standalone ouconnect-distributed.properties
para modo distribuído.Adicione a configuração do conector: No arquivo de propriedades, adicione as configurações específicas do conector de origem. Essas configurações podem variar dependendo do conector que você está usando. Consulte a documentação do conector para obter detalhes sobre as configurações necessárias e opcionais.
Inicie o Kafka Connect: Inicie o Kafka Connect novamente usando o script apropriado para sua configuração. Por exemplo, se você estiver usando o modo standalone, execute o comando
bin/connect-standalone.sh config/connect-standalone.properties
no diretório raiz do Kafka Connect.Verifique os logs: Verifique os logs do Kafka Connect para garantir que o conector de origem tenha sido configurado e inicializado corretamente. Você deve ver mensagens indicando a conexão bem-sucedida e o status do conector.
Certifique-se de revisar a documentação do conector específico para obter informações detalhadas sobre as configurações e propriedades necessárias.
Adicionando um destino
Para instalar um conector de destino (sink connector) no Kafka Connect, siga estas etapas:
Baixe o conector: Comece baixando o arquivo JAR do conector de destino que você deseja instalar. Você pode encontrar uma lista de conectores de destino disponíveis na seção de plugins do Kafka Connect no site do Confluent Hub (https://www.confluent.io/hub/).
Coloque o arquivo JAR no diretório de plugins do Kafka Connect: Após baixar o arquivo JAR, coloque-o no diretório de plugins do Kafka Connect. O diretório padrão é
<caminho_do_kafka_connect>/plugins
.Reinicie o Kafka Connect: Reinicie o Kafka Connect para que ele carregue o novo conector. Certifique-se de parar e iniciar o Kafka Connect corretamente.
Configure o conector: Abra o arquivo de propriedades do Kafka Connect correspondente ao modo que você está usando (standalone ou distribuído). O arquivo de propriedades é geralmente chamado de
connect-standalone.properties
para o modo standalone ouconnect-distributed.properties
para o modo distribuído.Adicione a configuração do conector: No arquivo de propriedades, adicione as configurações específicas do conector de destino. Essas configurações podem variar de acordo com o conector que você está usando. Consulte a documentação do conector para obter detalhes sobre as configurações necessárias e opcionais.
Inicie o Kafka Connect: Inicie o Kafka Connect novamente usando o script apropriado para sua configuração. Por exemplo, se você estiver usando o modo standalone, execute o comando
bin/connect-standalone.sh config/connect-standalone.properties
no diretório raiz do Kafka Connect.Verifique os logs: Verifique os logs do Kafka Connect para garantir que o conector de destino tenha sido configurado e inicializado corretamente. Você deve ver mensagens indicando a conexão bem-sucedida e o status do conector.
Lembre-se de revisar a documentação do conector específico para obter informações detalhadas sobre as configurações e propriedades necessárias.