Arquitetura de Integração

Funcionamento:

A solução utiliza o Kafka Connect para extrair dados do sistema legado através de consultas SQL e publicá-los em filas específicas do Kafka. O Spring Boot Cadastro é responsável por consumir as mensagens do Kafka, interpretar os dados e atualizar ou inserir os cadastros no sistema.

Detalhes da Implementação:

• Kafka Connect:

  • Conectores personalizados serão criados para cada tipo de dado (Dados Principais, Dados Referencias, Dados de Sócios e Dados de Endereço).

  • Cada conector irá realizar consultas SQL no banco de dados legado, buscando os dados relevantes para o seu tipo de informação.

  • A frequência das consultas será configurada de acordo com as necessidades do negócio.

  • Os dados extraídos serão publicados em filas específicas do Kafka.

• Spring Boot Cadastro:

  • Consumidores separados serão criados para cada fila de dados no Kafka, cada um responsável por um tipo específico de informação:

    • Fila-Dados-Principal: Dados principais (nome, CPF/CNPJ, etc.).

    • Fila-Dados-Socios: Dados de sócios de empresas (no caso de PJ).

    • Fila-Dados-Referencias: Dados de referencias pessoais e bancárias.

    • Fila-Dados-Endereco: Endereços associados aos cadastros.

  • Cada consumidor irá receber as mensagens, interpretar os dados e acionar o Service Atualização, responsável pela lógica de atualização ou inserção dos cadastros.