vek03/vekrest-veklambda

By vek03

•Updated 7 months ago

Lambda VekRest: consumer kafka via Spring Boot com Docker e Maven. Módulo 3 / Lambda

Image

Message queues

Web servers

4.9K

Overview Tags

vek03/vekrest-veklambda repository overview

⁠🧬 Projeto VekRest - VekLambda - Módulo 3

Lambda VekRest: consumer kafka via Spring Boot com Docker e Maven. Módulo 3 / Lambda

⁠🧩 PARTES DO MÓDULO 3

Aplicação	Descrição	Link
VekLambda	Lambda (este projeto) - Consumer Kafka	Este Repositório

Este projeto não depende de nenhuma outra aplicação para funcionar corretamente

⁠1.✨ Imagem Docker (DockerHub)

A imagem desta aplicação é atualizada a cada nova tag ou pull request na branch main⁠

Link da imagem no DockerHub: vek03/vekrest-veklambda:latest⁠

⁠1.1 🧩 Containers necessários para rodar a aplicação:

Container	Imagem	Link
MongoDB	`mongo:latest`	https://hub.docker.com/_/mongo⁠
OpenSearch	`opensearchproject/opensearch:2.4.0`	https://hub.docker.com/layers/opensearchproject/opensearch/2.4.0/images/sha256-c8681472b70d46e7de61fe770d288a972f84b3f122f3c74ca06ea525264b6fd5⁠
Graylog	`graylog/graylog:5.1.5`	https://hub.docker.com/layers/graylog/graylog/5.1.5/images/sha256-3b6967572e88731eacfa661e6d7ca41da3e259bc5eb041e58fb10e4deb823dcb⁠
Zookeeper	`confluentinc/cp-zookeeper:7.5.0`	https://hub.docker.com/layers/confluentinc/cp-zookeeper/7.5.0/images/sha256-d18e7b3a81326dd278a5f2121b29a7f009582e0b0f5552165eb5efc83533a52b⁠
Kafka	`confluentinc/cp-kafka:7.5.0`	https://hub.docker.com/layers/confluentinc/cp-kafka/7.5.0/images/sha256-69022c46b7f4166ecf21689ab4c20d030b0a62f2d744c20633abfc7c0040fa80⁠

⁠1.2 ⚙ Variáveis de ambiente necessárias para rodar o container:

Variável	Descrição	Exemplo
`KAFKA_BROKERS`	Endereço do broker Kafka	`kafka:9092`
`KAFKA_REPLICAS`	Número de réplicas do Kafka	`1`
`KAFKA_PARTITIONS`	Partição do tópico Kafka	`3`
`GRAYLOG_HOST`	Endereço do Graylog	`graylog`
`GRAYLOG_PORT`	Porta do Graylog	`12201`

⁠1.3 🐳 Como rodar o container

1️⃣ Para baixar a imagem do Docker Hub:

docker pull vek03/vekrest-veklambda:latest

2️⃣ Para rodar o container localmente:

docker run -d \
  --name veklambda \
    -e KAFKA_BROKERS=kafka:9092 \
    -e KAFKA_REPLICAS=1 \
    -e KAFKA_PARTITIONS=3 \
    -e GRAYLOG_HOST=graylog \
    -e GRAYLOG_PORT=12201 \
  vek03/vekrest-veklambda:latest

3️⃣ Alternativamente, você pode adicionar o serviço no seu docker-compose.yml local, descomentando ou adicionando o seguinte trecho:

services:
  veklambda:
    image: vek03/vekrest-veklambda:latest
    hostname: veklambda
    container_name: veklambda
    environment:
      KAFKA_BROKERS: kafka:9092
      KAFKA_REPLICAS: 1
      KAFKA_PARTITIONS: 3
      GRAYLOG_HOST: graylog
      GRAYLOG_PORT: 12201
    depends_on:
      mongodb:
        condition: service_healthy
      opensearch:
        condition: service_healthy
      graylog:
        condition: service_started
      zookeeper:
        condition: service_healthy
      kafka:
        condition: service_healthy

4️⃣ Depois de adicionar o serviço em docker-compose.yml, suba os containers:

docker-compose up -d

⁠📦 Instalação e Configuração do Ambiente

⁠1️⃣ Clone o projeto na sua máquina e baixe as dependências:

# Clonar
git clone https://github.com/VekRest/vekrest-veklambda-modulo3.git

# Acesse a pasta do projeto
cd vekrest-veklambda-modulo3

⁠2️⃣ Suba os containers necessários e Rode o projeto na sua IDE de preferência (ou via comando Maven)

# Suba os containers necessários (MongoDB, Redis, OpenSearch, Graylog)
docker-compose up -d

# Agora abra o projeto na sua IDE (IntelliJ, Eclipse, VSCode, etc) e rode a aplicação Spring Boot
# Ou, se preferir, rode via terminal com properties-local:
mvn spring-boot:run -pl spring -Dspring-boot.run.jvmArguments="-Dspring.profiles.active=local"

⁠3️⃣ (Opcional) Alternativamente, se quiser rodar via container localmente:

# Dentro da pasta do projeto:
mvn clean package -DskipTests

# Agora faça deploy no Docker local:
docker build -t vekrest/veklambda:latest .

# Descomente as últimas linhas do docker-compose.yml (relacionadas ao veklambda) e rode:
docker-compose up -d

Ou execute o script .bat (executar_tudo.bat) na pasta .commands para automatizar o processo.

⁠4️⃣ (Opcional) Caso deseje, pode rodar o SonarQube localmente

# Após configurar o pom.xml com as informações do Sonar em Properties:
mvn clean install sonar:sonar -Dsonar.token={TOKEN_SONAR}

⁠📨 Como testar o Consumer Kafka

Com a aplicação rodando, você pode enviar mensagens para o tópico Kafka "client.registered" e verificar se o consumer está recebendo as mensagens corretamente.

⁠Exemplos de mensagens para enviar ao tópico Kafka

⁠Exemplo de mensagem JSON para enviar ao tópico Kafka

{
  "name": "Vek",
  "birth": "2023-01-01",
  "address": {
    "cep": "03759040",
    "state": "SP"
  }
}

⁠Exemplo de mensagem hexadecimal para enviar ao tópico Kafka

# key
6b6579

# value
7b226e616d65223a2256656b222c226269727468223a22323032332d30312d3031222c2261646472657373223a7b22636570223a223033373539303430222c227374617465223a225350227d7d

⁠Comandos para enviar a mensagem via terminal:

# Acesse o container do Kafka
docker exec -it kafka bash

# Envie uma mensagem para o tópico "client.registered"
echo '{"name":"Vek","birth":"2023-01-01","address":{"cep":"03759040","state":"SP"}}' | kafka-console-producer --broker-list localhost:9093 --topic client.registered

# Você deve ver a mensagem sendo consumida no console da aplicação VekLambda

⁠🧩 Tecnologias Utilizadas

Spring Boot → Framework Back-End
Java → Linguagem de programação
Maven → Build
Docker → Containers e virtualização
GraalVM → Compilação nativa (opcional)
Docker Hub → Repositório de imagens Docker
Kafka → Mensageria
Zookeeper → Gerenciamento do Kafka
MongoDB → Banco de Dados NoSQL
OpenSearch e Graylog → Logs da Aplicação
SonarQube → Qualidade
Github Actions → CI/CD automatizado
.bat → Scripts para automatizar processos no Windows

⁠✅ Qualidade (SonarQube)

Este projeto tem qualidade analisada pelo SonarQube Cloud. Verifique nos badges!

⁠📦 Esteira CI/CD Automatizada com Github Actions

A esteira CI/CD deste projeto é automatizada via Github Actions. A cada tag criada a esteira é disparada.

⁠Para executar a Esteira pelo trigger:

# Exemplo: Cria a tag
git tag <version>

# Envia a tag para o repositório remoto
git push origin <version>

Tag summary

Recent tags

Content type

Image

Digest

sha256:1b0ea20aa…

Size

207 MB

Last updated

7 months ago

docker pull vek03/vekrest-veklambda:v1.0.0