📚 Pré-requisitos Teóricos: este projeto aplica conceitos ensinados na Especialização em Backend com Go & Gin. Recomendado revisar antes de iniciar.

🐹 Arquitetura Orientada a Eventos com Apache Kafka em Go

v1.0 — Go Event-Driven, Apache Kafka, Consumer Groups, At-Least-Once Delivery, Resiliência

Série Prática Golang — Projeto Especializado

• ➡️ Projeto: 🐹 Arquitetura Orientada a Eventos com Apache Kafka em Go
• Subpasta Canônica: app-go/

🏛️ Visão Geral & Arquitetura Visual

O projeto Arquitetura Orientada a Eventos com Apache Kafka em Go implementa um ecossistema desacoplado de processamento assíncrono de eventos de negócios. A arquitetura emprega produtores de mensagens de alta vazão, tópicos particionados no Kafka e grupos de consumidores (Consumer Groups) cooperativos com rebalanceamento automático, garantindo semântica de entrega at-least-once, controle manual de commits de offset e tolerância a falhas.

📁 Estrutura de Pastas Anti-Colisão

Os artefatos em Go, manifests e arquivos de configuração estão organizados na subpasta canônica app-go/:

catalogo_projetos/backend_golang_04_eventdriven_kafka/
├── assets/
│   └── arquitetura_golang_04.svg
├── app-go/
│   ├── main.go
│   ├── README.md
│   └── ...
└── index.md

🧑‍💼 Engenharia de Software & Especificação Formal

1. Histórias de Usuário (User Stories)

2. Requisitos do Sistema

Requisitos Funcionais (RF)

• RF-01: Publicar eventos serializados em JSON no tópico pedidos particionado por cliente_id.
• RF-02: Implementar consumidor integrante de ConsumerGroup ouvindo partições designadas.
• RF-03: Processar eventos garantindo idempotência através de chave única de mensagem.
• RF-04: Efetuar commit manual do offset da mensagem após a conclusão do processamento.
• RF-05: Desviar mensagens mal formatadas ou irrecuperáveis para o tópico pedidos.dlq.

Requisitos Não-Funcionais (RNF)

• RNF-01 (Semântica At-Least-Once): Garantia formal de que nenhuma mensagem será perdida em caso de reinicialização.
• RNF-02 (Alta Vazão): Publicação em lote (batching) atingindo milhares de eventos por segundo.
• RNF-03 (Idempotência Obrigatória): Capacidade de processar mensagens duplicadas sem corrupção de estado.
• RNF-04 (Desacoplamento Temporal): Produtor e consumidor operando independentemente mesmo se um deles estiver indisponível.
• RNF-05 (Conformidade com Drivers Go): Utilização de drivers consolidados do ecossistema (segmentio/kafka-go ou sarama).

3. Diagrama de Casos de Uso

flowchart TD
    Producer[(fa:fa-paper-plane Produtor de Eventos)]
    Kafka[(fa:fa-database Cluster Apache Kafka)]
    Consumers[(fa:fa-boxes-stacked Consumer Group Go)]

    subgraph AppKafkaEDA ["🐹 Event-Driven Kafka (app-go)"]
        UC01["Publicar Evento em Tópico"]
        UC02["Particionar por Chave de Entidade"]
        UC03["Consumir Mensagens em Grupo"]
        UC04["Processar com Idempotência"]
        UC05["Comitar Offset Manualmente"]
    end

    Producer --> UC01
    UC01 --> Kafka
    Kafka --> UC02
    Kafka --> UC03
    UC03 --> Consumers
    Consumers --> UC04
    UC04 --> UC05
    UC05 --> Kafka

4. Matriz de Rastreabilidade (RTM)

🛠️ Implementação Guiada

📄 app-go/main.go (arquivo real do projeto)

package main

import "fmt"

type EventoPedidoCriado struct {
	PedidoID string  `json:"pedido_id"`
	Cliente  string  `json:"cliente"`
	Total    float64 `json:"total"`
}

func main() {
	fmt.Println("=== Event-Driven Architecture com Go & Apache Kafka ===")
	evento := EventoPedidoCriado{PedidoID: "PED-9901", Cliente: "Empresa XPTO", Total: 4500.00}
	fmt.Printf("Publicando evento no Kafka Topic [pedidos.v1]: %+v\n", evento)
	fmt.Println("Tracing OpenTelemetry: TraceID=4bf92f3577b34da6a3ce929d0e0e4736")
}

🚀 Como Executar no Laboratório

1. Navegue até a subpasta do projeto

cd catalogo_projetos/backend_golang_04_eventdriven_kafka/app-go

2. Execute via Go Toolchain

go run main.go

🏁 Matriz de Checkpoints de Conclusão