Expand description
Test-only Kafka wire tap.
The tap is a TCP relay. It tees complete frames to a Recorder, and at the
same time it forwards the bytes byte-for-byte to a real broker.
Modules§
- frame
- Kafka wire framing, and request and response correlation. This module has no schema knowledge.
Functions§
- spawn
- Bind a listener, accept connections, relay each one to
upstream, and record the frames.
Type Aliases§
- Recorder
- Callback invoked once per fully-read frame in either direction.