streaming: provide a stream client #57424
Labels
A-disaster-recovery
C-enhancement
Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception)
T-disaster-recovery
As described in the cluster-streaming RFC, the ingestion job interacts with the incoming stream via a stream client.
The initial version of the stream client should be on top of the KV-encoded core changfeed implemented by #57422. It should be able to read from this stream and produce all of the KV events emitted on it.
The text was updated successfully, but these errors were encountered: