Exemplo de implementação de um micro serviço produtor de mensagens para o kafka utilizando o Spring Boot.
#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 cliente-producer
- Subir as duas aplicações através da classe SpringApplication
-
Fazer uma requisição POST
curl --location --request POST 'http://localhost:8080/cliente/' \ --form 'id="1"' \ --form 'nome="Deyvid Fernandes"' \ --form 'idade="33"'
-
Resultado esperado é produzir uma mensagem no formato json no tópico DEV.CLIENTE, uma forma de validar é exeutando o seguinte comando:
docker exec -ti broker ../../bin/kafka-console-consumer --bootstrap-server localhost:9092 --topic DEV.CLIENTE --from-beginning