Skip to content

leandroandrade/sample-kafka-consumer-ts

Repository files navigation

sample-kafka-consumer-ts

Boostrap para consumer kafka usando Typescript.

Começando

Para inciar o projeto no ambiente local, renomear o arquivo .env.development para .env

Iniciando kafka broker:

Para iniciar o broker Kafka no ambiente local, executar os comandos:

  1. Iniciar ambiente:
docker-compose up -d

O broker será iniciado no endereço localhost:9094

  1. Finalizar ambiente:
docker-compose down

Scripts disponíveis:

  1. Executar os testes:
npm test
  1. Executar aplicação no ambiente local:
npm run dev
  1. Build da aplicação:
npm run build
  1. Executar aplicação:
npm start

Enviando mensagens pelo producer

Após a aplicação ter sido iniciada no ambiente de local, podemos enviar mensagens para o consumer da seguinte forma:

  1. Entrar no container kafka:
docker exec -ti sample-kafka-consumer-ts_kafka_1 bash
  1. Utilizar console do producer:
kafka-console-producer --bootstrap-server localhost:9092 --topic bank001

Com o console do producer iniciado, digite uma mensagem. Essa deverá ser recebida pela consumer.

Licença

Este projeto está licenciado sob a Licença MIT - consulte o arquivo LICENSE.md para obter detalhes

About

Minimalist kafka consumer with Typescript.

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published