Building a session-ordered Kafka pipeline in Go (InfoQ)
An InfoQ article describes a Go-based design for preserving per-session ordering over Kafka using consistent hashing, a two-level worker hierarchy, and one goroutine per active session. The author explains in-place retries, contiguous watermark commits, and operational hardening (rebalance draining, backpressure, idempotency, dead-letter queues) and reports the system has processed >40M production messages with no observed ordering violations and achieved >100k send-side messages/sec in tests.