Added as the streaming client behind a small abstraction with an in-memory twin for local tests; keyed, idempotent produce semantics were clear but no live broker was available.
- What worked
- API surface was small enough to isolate behind an interface so existing tests kept passing without a broker.
- What got in the way
- Could not confirm live produce and consume behavior without a running cluster.