Conector Apache Kafka para Jitterbit Integration Studio

Resumo

O conector Apache Kafka estabelece acesso ao Apache Kafka.

O conector Apache Kafka fornece uma interface para criar uma conexão Apache Kafka, a base usada para gerar instâncias de atividades do Apache Kafka. Essas atividades, uma vez configuradas, interagem com o Apache Kafka por meio da conexão.

O conector Apache Kafka é acessado na aba endpoints e conectores do projeto da paleta de componentes de design (consulte paleta de componentes de design).

Visão geral do conector

Este conector é usado para configurar primeiro uma conexão Apache Kafka. Os tipos de atividade associados a essa conexão são então usados para criar instâncias de atividades que devem ser usadas como fontes (para fornecer dados em uma operação) ou destinos (para consumir dados em uma operação).

Juntas, uma conexão específica do Apache Kafka e suas atividades são chamadas de endpoint do Apache Kafka:

• Enviar mensagem: Envia fluxos de dados para um tópico em um cluster Apache Kafka e se destina a ser usado como alvo em uma operação.

• Obter mensagens: Recupera fluxos de dados de um tópico em um cluster Apache Kafka e se destina a ser usado como fonte em uma operação.

Nota

Este conector é um Connector SDK, que pode ser referenciado pelo Jitterbit ao comunicar alterações feitas em conectores criados com o Connector SDK.

Pré-requisitos e versões de API suportadas

O conector Apache Kafka requer o uso de uma versão de agente 10.1 ou posterior. Essas versões de agente baixam automaticamente a versão mais recente do conector quando necessário.

O conector Apache Kafka usa a API principal do Apache Kafka. Consulte a documentação da API para obter informações sobre os nós e campos do esquema.

Solução de problemas

Se você tiver problemas com o conector Apache Kafka, estas etapas de solução de problemas são recomendadas:

1. Clique no botão Testar na configuração de conexão para garantir que a conexão seja bem-sucedida e que a versão mais recente do conector seja baixada para o agente (a menos que esteja usando a política da organização Desativar atualização automática do conector).

2. Verifique os registros de operação para qualquer informação escrita durante a execução da operação.

3. Habilite o registro de depurar da operação (para agentes de nuvem ou para agentes privados) para gerar arquivos de log e dados adicionais.

4. Se estiver usando agentes privados, você pode habilitar conector verbose logging para este conector usando esta entrada de configuração específica de nome e nível do registrador:

   <logger name="org.jitterbit.connector.apache.kafka" level="DEBUG"/>
   

5. Se estiver usando agentes privados, você pode verificar os registros do agente para mais informações.

6. Para considerações adicionais sobre solução de problemas, consulte Solução de problemas de operação.