Don't buffer postgres sources messages as aggressively #12557
Labels
A-STORAGE
Topics related to the Storage layer
C-refactoring
Category: replacing or reorganizing code
In #11946, we buffer messages from the pg source in 2 places. We should strive to remove one or both of these:
InProgress
in the reclocking process. TheReclockOperator
can likely be adjusted to hand out a timestamp but not seal off that timestamp for offsets that have not reachedFinalized
status cc @cjubb39InProgress
messages and sendFinalized
messages at the endThe text was updated successfully, but these errors were encountered: