Millipede Academy

Book 4 · Lesson 4.5

Rust consumer skeleton

  • Create StreamConsumer with group.id
  • Loop recv → parse → handle errors
  • Locate run_consumer in analyzer

Prerequisites: 4.4

The analyzer spawns run_consumer in a background task — HTTP server and consumer share AppState.

Step ConsumerLoopVisualizer alongside services/analyzer/src/main.rs.

Consumer settings

SettingValue
group.idmillipede-analyzer
auto.offset.resetearliest
Topic (default)enriched-dev-events (Stage 3 path)

Stage 1 lab: run analyzer with Kafka + Postgres; consumer persists events.

Teach-back prompt

What happens if two analyzer instances share the same group.id?

Analyzer consumer loop

Lesson 4.5 check

1. Analyzer consumer group id…