Kafka Consumer

Descrição

Exemplo de implementação de um micro serviço consumidor de mensagens para o kafka utilizando o Spring Boot.

Índice

• Descrição
• Índice
• Como Usar
• Testes
• Status

Como Usar

#Pré Requesitos

• Java 14
• Docker instalado

#Subindo Aplicação

• Clonar repositório
• Navegar até a pasta do arquivo docker-compose.yml
• Rodar comando docker-compose up -d
• Validar se foi tudo criado e está UP com o comando docker-compose ps
• Abrir o projeto cadastro-consumer
• Subir as duas aplicações através da classe SpringApplication

Testes

• Criar tópico com 3 partições

  docker exec -ti broker ../../bin/kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic DEV.CUSTOMER

• Subir a aplicação

• Produzir uma mensagem

  docker exec -ti broker ../../bin/kafka-console-producer --broker-list localhost:9092 --topic DEV.CUSTOMER

• Resultado esperado

  1- A mensagem cair em apenas um dos métodos da classe CustomerOneConsumer 2- A mensagem cair nos dois métodos da classe CustomerTwoConsumerGroup

Status

🚧 kafka - Em construção... 🚧