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": "erna_doyle@undefined.hu",
			"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.

Exemplo de corpo de requisição:

{
	"timer": 500,
	"data": []
}

Links úteis

KafkaJS documentação oficial

Apache Kafka documentação oficial

Entendendo o Apache Kafka II - Medium

Uma breve introdução ao Kafka