consumer

Documentation

Overview

Command consumer demonstrates a shunt router with a multi-step retry chain, a DLQ, and per-topic worker caps.

Run a local Kafka (e.g. a single-broker KRaft container), create the topics, then:

KAFKA_BROKERS=localhost:9092 go run ./examples/consumer

Messages whose value contains "fail" always fail, so they walk the whole chain: 2 inline retries, 2 delayed attempts via orders.retry.10s, one via orders.retry.1m, and finally orders.dlq.