WELLINGTON COSTA
hub Event-Driven Architecture

The Pulse

Um sistema de notificações distribuído de alta volumetria construído com base em eventos. Projetado para garantir a entrega de mensagens em escala através de processamento assíncrono com Apache Kafka e resiliência com estratégias de DLQ.

Linguagem Java 21
Framework Spring Boot 3.2
Mensageria Apache Kafka
Banco de Dados PostgreSQL 16
Containerização Docker
Migrations Flyway

Diferenciais e Funcionalidades

bolt

Processamento Assíncrono

Produtor e Consumidor completamente desacoplados através do Apache Kafka, permitindo alta escalabilidade e vazão de mensagens.

sync

Resiliência e DLQ

Configuração avançada de retentativas com Exponential Backoff e uso de Dead Letter Queue para tratar mensagens com falhas críticas.

route

Rastreabilidade (Tracing)

Injeção de correlationId nos headers das mensagens Kafka para rastreamento completo de ponta a ponta em sistemas distribuídos.

rule

Validação bean (JSR 380)

Payloads validados na entrada com feedback claro de falhas através de um Global Exception Handler padronizado.

checklist

Testes Automatizados

Ampla cobertura de testes de unidade com JUnit 5 e Mockito, garantindo a estabilidade das regras de negócio.

database

Persistência Confiável

Log de notificações persistido em PostgreSQL com controle automático de migrações de esquema via Flyway.

Arquitetura e Fluxo Interativo

send
Origem
input
Producer API
reorder
Apache Kafka
settings_input_component
Consumer Service
database
PostgreSQL
priority_high
DLQ
info

Explore o Fluxo

Passe o mouse sobre os componentes ou clique em "Simular" para entender como as notificações são processadas.

Gostou desta arquitetura?

The Pulse demonstra como construir sistemas resilientes e escaláveis utilizando os melhores padrões de mensageria e desacoplamento.