Skip to main content

Kafka Topics 📡

This document describes the Kafka topics used in ShopVerse, their purpose, producers, and consumers.

Kafka acts as the event backbone of the system, enabling loose coupling, scalability, and asynchronous processing.

🎯 Why Kafka in ShopVerse?​

Kafka is used to:

  • Decouple microservices
  • Handle async workflows
  • Prevent cascading failures
  • Enable analytics & recommendations
  • Support future extensibility

🗂️ Topic Overview​

Topic NamePurpose
auth-eventsAuthentication-related events
product-eventsProduct lifecycle events
order-eventsOrder lifecycle events
payment-eventsPayment status events
analytics-eventsUnified analytics stream

🔐 auth-events​

📌 Purpose​

Tracks authentication-related actions.

📤 Producers​

  • Auth Service

📥 Consumers​

  • Notification Service
  • Analytics Service

📦 Event Types​

  • USER_REGISTERED
  • USER_LOGIN

📦 product-events​

📌 Purpose​

Tracks product catalog changes.

📤 Producers​

  • Product Service

📥 Consumers​

  • Notification Service
  • Analytics Service
  • Recommendation Service

📦 Event Types​

  • PRODUCT_CREATED
  • PRODUCT_UPDATED
  • PRODUCT_DELETED
  • PRODUCT_STOCK_UPDATED

🧾 order-events​

📌 Purpose​

Tracks order lifecycle changes.

📤 Producers​

  • Order Service

📥 Consumers​

  • Notification Service
  • Analytics Service
  • Recommendation Service

📦 Event Types​

  • ORDER_PLACED
  • ORDER_STATUS_UPDATED

💳 payment-events​

📌 Purpose​

Tracks payment lifecycle.

📤 Producers​

  • Payment Service

📥 Consumers​

  • Notification Service
  • Analytics Service
  • Order Service (optional sync)

📦 Event Types​

  • PAYMENT_CREATED
  • PAYMENT_SUCCESS
  • PAYMENT_FAILED

📊 analytics-events​

📌 Purpose​

Unified stream for analytics processing.

📤 Producers​

  • All core services

📥 Consumers​

  • Analytics Service (Flink job)

📌 Naming Conventions​

  • Topic names use kebab-case
  • Event types use UPPER_SNAKE_CASE
  • One topic per domain

📈 Scalability Notes​

  • Topics are partitioned
  • Consumer groups enable horizontal scaling
  • Producers are stateless

📌 Summary​

Kafka topics in ShopVerse are:

  • Domain-driven
  • Clearly scoped
  • Easy to extend
  • Production-aligned

They form the communication contract between services.