Congratulations Michael, great findings recently!
On Fri, Dec 3, 2021 at 11:49 AM Aloys Zhang wrote:
> [ External sender. Exercise caution. ]
>
> Congrats Micheal !
>
> Lan Liang 于2021年12月3日周五 18:47写道：
>
> > Congrats :)
> >
> >
> >
> >
> >
> >
> >
> > Best Regards,
> > Lan Liang
> > On 12/3/202
Hi Enrico,
This is interesting. I'm thinking of the KTables part of Kafka Streams and
also Raft state machines.
You could build something equivalent to a Raft state machine on top of
Pulsar where WaitForExclusive acts as leader election and the topic as the
log. I would be interested in a PIP, th
I can see both sides of the argument regarding whether to flush pending
messages or not. But I think what is definitely in the contract is not to
discard any callbacks causing user code to block forever. No matter what,
we must always call the callbacks.
Personally, I am in favour of a close opera
