Backlog distribution problem with SubscriptionType.Key_Shared

2022-11-15 Thread Tarun Annapareddy
Hi, I am exploring the Key_Shared feature of Apache Pulsar using the Pulsar 2.10.1 client. *UseCase Perspective:* I am simulating an everyday use case in Kubernetes-based deployments. when we deploy new code to the pod's consumers restart, the first consumer that starts is picking all the back

Re: PIP-Java Client support to Cumulative Acknowledge messages for multiple partitions or topics

2022-09-14 Thread Tarun Annapareddy
, but I don't > > think that adding a dummy parameter to the API will really > > help. > > There is no way to confirm that the MessageId really belongs to the > > partition and you can pass whatever you want > > > > Enrico > > > > > > &g

Re: [DISCUSS] User-friendly acknowledgeCumulative API on a partitioned topic or multi-topics

2022-09-13 Thread Tarun Annapareddy
Hi, There is a concern about the validation of the topic string key in the map we are using. In this case is it good to have Map topicToMessage? It will help us to validate that the message truly belongs to the topic/partition. Thank you, Tarun. On Fri, 9 Sept 2022 at 19:55, Xiangying Meng wro

PIP-Java Client support to Cumulative Acknowledge messages for multiple partitions or topics

2022-09-13 Thread Tarun Annapareddy
Hi devs, This is the official thread to vote for Java Client support to Cumulative Acknowledge messages for multiple partitions or topics PIP Issue: https://github.com/apache/pulsar/issues/17574 Discussion thread: https://lists.apache.org/thread/k090ftlqc149yr1cnprxb29vxg160131 PR: https://git

Re: [DISCUSS] User-friendly acknowledgeCumulative API on a partitioned topic or multi-topics

2022-09-10 Thread Tarun Annapareddy
Hi, I have created PR to support the below functionality, Please provide feedback. *Method:* void acknowledgeCumulative(Map topicToMessageId); *Pull Request:* https://github.com/apache/pulsar/pull/17577 Thanks & Regards Tarun. On Fri, 9 Sept 2022 at 19:55, Xiangying Meng wrote: > +1 > This