The synchronized consumer does not fit terribly well in the dataflow primitives.
We need to find out how to make a stream progress only when another commit log provides a watermark.
Is it something we should express outside of the dataflow primitives ?
The synchronized consumer does not fit terribly well in the dataflow primitives.
We need to find out how to make a stream progress only when another commit log provides a watermark.
Is it something we should express outside of the dataflow primitives ?