Aplicação desenvolvida na formação Kafka da Alura

• Curso de Kafka: Produtores, Consumidores e streams
• Kafka: Fast delegate, evolução e cluster de brokers
• Kafka: Batches, correlation ids e dead letters
• Kafka: Idempotência e garantias

• Kafka
• Java
• SQLite

• Commom Kafka
  • Módulo base para utilizar o Kafka
• Commom Database
  • Módulo para utilizar o banco de dados SQLite
• Service Email
  • Serviço que lê o tópico de e-mail
• Service Email New Order
  • Serviço que lê o tópico de e-mail e faz o direcionamento para o Service Email
• Service Fraud Detector
  • Serviço que lê o tópico de new-order e verifica se o pedido é uma fraude
• Service Log
  • Serviço que gera os logs lendo todos os tópicos gerados para ecommerce
• Service New Order
  • Serviço de criação de tópicos (new-order e e-mail)
• Service Users
  • Serviço para criação de um usuário usuário no banco de dados (SQLite)
• Service HTTP Ecommerce
  • Serviço o envio de Orders por requisições HTTP
• Service Reading Report
  • Serviço que faz o envio de relatórios para todos os usuários

http://localhost:8080/[email protected]&amount=1999&uuid=f76ec663-acdc-4ba3-8c5f-f827e006abdf

Start kafka server

./bin/kafka-server-start.sh config/server.properties

O zookeeper é utilizado para armazenar as mensagens do Kafka, por essa razão é necessário baixa-lo.

Start zookeeper

./bin/zookeeper-server-start.sh config/zookeeper.properties

Create a new topic

./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic LOJA_NOVOPEDIDO

List topics created

./bin/kafka-topics.sh --list --bootstrap-server localhost:9092

Insert messages in topic

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic LOJA_NOVOPEDIDO

If you want to get from the first message to last, use: --from-beginning

Read message from topic

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ECOMMERCE_NEW_ORDER --from-beginning

Developed by Jean Jacques