Any updates on this?
On 2022/09/11 04:18:07 Qiang Huang wrote:
> Hi Asaf, thank you for the very detailed reply.
>
> > The problem we have today is that while we have sent a request to reset
> the subscription position, the broker decides to:
> > 1. Close the TCP connection which in turn causes t
Did you end up fixing the PIP? I see it wasn’t implemented at the end.
On 11 Sep 2022 at 7:18:07, Qiang Huang wrote:
> Hi Asaf, thank you for the very detailed reply.
>
> The problem we have today is that while we have sent a request to reset
>
> the subscription position, the broker decides t
Hi Asaf, thank you for the very detailed reply.
> The problem we have today is that while we have sent a request to reset
the subscription position, the broker decides to:
> 1. Close the TCP connection which in turn causes the client to clear any
pending messages it has in the queue.
> 2. Continue
Hi Qiang,
We have a brainstorming session on this PIP over Zoom with Penghui, Hang,
and more people, and I'm jotting down here our feedback.
Before I do that, I just want to write my own understanding of the
document, for other readers:
# Context
Pulsar, as opposed to other distributed / streami
Sure. You can refer to pip-84:
https://github.com/apache/pulsar/wiki/PIP-84-:-Pulsar-client:-Redeliver-command-add-epoch
.
Zike Yang 于2022年7月29日周五 10:22写道：
> Hi, Qiang
>
> > It is necessary to check the current cursor status when handling
> flowPermits
> > request from the server side. If the se
Hi, Qiang
> It is necessary to check the current cursor status when handling flowPermits
> request from the server side. If the server is handling seek request, it
> should ignore flowPermits request because the request is illegal.
Thanks for your explanation. I think it's better to add this
expl
Thanks Zike.
> > - stage 1: Check the current cursor status when handling flowPermits
from
> > the server side.
> > Could you explain more details on this step? It looks like there is
not much described above. What kind of status needs to be checked, and
what kind of behavior will the broker take?
Hi, Qiang Huang.
This is a good proposal to solve the seek issue of readers. Overall
looks good to me. Left some comments here. Thanks.
> > - stage 1: Check the current cursor status when handling flowPermits from
> > the server side.
Could you explain more details on this step? It looks like the
+1, Good work.
Thanks,
Xiaoyu Hou
Qiang Huang 于2022年7月24日周日 22:25写道：
> Hi Pulsar community:
> I open a pip to discuss "Pulsar client: seek command add epoch"
> Proposal Link:
>
>- issue link: https://github.com/apache/pulsar/issues/16757
>
> --
> ## Motivation
> `Reader` belongs to exclusiv
+1, good idea!
Thanks,
Zixuan
Qiang Huang 于2022年7月24日周日 22:25写道：
> Hi Pulsar community:
> I open a pip to discuss "Pulsar client: seek command add epoch"
> Proposal Link:
>
>- issue link: https://github.com/apache/pulsar/issues/16757
>
> --
> ## Motivation
> `Reader` belongs to exclusive
Hi Pulsar community:
I open a pip to discuss "Pulsar client: seek command add epoch"
Proposal Link:
- issue link: https://github.com/apache/pulsar/issues/16757
--
## Motivation
`Reader` belongs to exclusive subscription type, and it uses `nonDurable`
cursor. After receiving messages, `Reader`
11 matches
Mail list logo
