streaming: create stream ingestion job #57399
Labels
A-disaster-recovery
C-enhancement
Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception)
T-disaster-recovery
A new type of job is needed to consume a partitioned stream.
The job should:
The initial version will explicitly not require coordination of resolved timestamps across processors to keep track of the low-watermark.
The text was updated successfully, but these errors were encountered: