Thank you for your responses and suggestions. I appreciate it.
Albert
On Wed, Apr 26, 2017 at 4:19 AM, Ufuk Celebi wrote:
> Adding to what Zhijiang said: I think the way to go would be to create
> multiple "read views" over the pipelined subpartition. You would have
> to make sure that the init
Adding to what Zhijiang said: I think the way to go would be to create
multiple "read views" over the pipelined subpartition. You would have
to make sure that the initial reference count of the partition buffers
is incremented accordingly. The producer will be back pressured by
both consumers now.