node-kafka's Introduction

Node-kafka

Base de estudos em stream de eventos / mensageira, onde a proposta inicial foi realizar uma introdução a produção e consumo de mensagens utilizando Node e Kafka, convertendo uma carga entre 500 a 1000 solicitações do mesmo serviço em mensagens enfileiradas a serem consumidas no "tempo do servidor"

Tecnologias utilizadas

Utilização

Clone o repositório;
Instale as dependências com yarn ou npm install;
Construa o broker Apache Kafka e MongoDB com docker-compose up

Mapeamento

Portas

localhost:9000 - consumer api
localhost:3333 - producer api
localhost:9092 - container Broker Kafka
localhost:2181 - container Zookeeper
localhost:27017 - container MongoDB

Rotas

Consumer api:

Buscar todos os usuários cadastrados:

GET http://localhost:9000/users

Exemplo de retorno da busca por usuários:

{
	"count": 1,
	"users": [
		{
			"_id": "6265c461b8a8aab3196ff9c1",
			"email": "[email protected]",
			"name": "Erna",
			"createdAt": "2022-04-24T21:42:57.889Z",
			"updatedAt": "2022-04-24T21:42:57.889Z",
			"__v": 0
		}
  ]
}

Delete todos os usuários:

DELETE http://localhost:9000/users

Producer api:

Enviar usuários para a fila:

POST http://localhost:3333/

Parâmetros de corpo da requisição:

Nome	Tipo	Descrição
timer	Número	Tempo de espera entre cada produção em milissegundos
data	Matriz	Matriz de usuários a serem cadastrados. Quando vazia, os usuários fakes são buscados do JSON GENERATOR.