[GitHub] [pulsar] crossoverJie added a comment to the discussion: Is it possible to manually acknowledge messages via msgId?

GitHub user crossoverJie added a comment to the discussion: Is it possible to manually acknowledge messages via msgId? Thanks for the answer, Before this I thought that `individuallyDeletedMessages` stored unacknowledged messages. --- Here is my testing process: ```java "individuallyDeletedM

[GitHub] [pulsar] crossoverJie added a comment to the discussion: Is it possible to manually acknowledge messages via msgId?

GitHub user crossoverJie added a comment to the discussion: Is it possible to manually acknowledge messages via msgId? The background to my doing this is as follows: I want to know if the backlog of message topics is caused by message holes. If so, I would like to manually acknowledge these h

Re: [ANNOUNCE] New Committer: Cong Zhao

Congrats! Cong Thanks, Penghui > On Nov 21, 2022, at 13:57, Zixuan Liu wrote: > > Congrats! Cong > > Best Regards, > Zixuan > > houxiaoyu 于2022年11月21日周一 12:24写道： > >> Congrats! Cong >> >> Best, >> Xiaoyu Hou >> >> Haiting Jiang 于2022年11月21日周一 12:10写道： >> >>> The Project Management Commi

[DISCUSS] Release Pulsar Client C++ 3.1.0

Hi everyone, I would like to propose releasing the Pulsar Client C++ 3.1.0 There are several new features and bug fixes in the main branch[0]. And it’s time to release a new version. Please remind me if you have any important fixes that need to be included in 3.1.0 [0] https://github.com/apache/

Re: [ANNOUNCE] New Committer: Cong Zhao

Congratulations, Cong @coderzc ! From: PengHui Li Sent: Monday, November 21, 2022 17:13 To: dev@pulsar.apache.org Subject: Re: [ANNOUNCE] New Committer: Cong Zhao Congrats! Cong Thanks, Penghui > On Nov 21, 2022, at 13:57, Zixuan Liu wrote: > > Congrats! Cong

Re: [DIDSCUSS] Realease Pulsar 2.9.4 cherry-pick done

I have cherry-picked all pr labeled release/2.9.4, so I will start releasing pulsar-2.9.4v. Thanks, Bo Yunze Xu 于2022年11月18日周五 11:31写道： > > https://github.com/apache/pulsar/pull/18486 should be cherry-picked to > 2.9.4 because it fixes a bug introduced in > https://github.com/apache/pulsar/pull/

[DISCUSS] Modify MessageIdImpl and BatchMessageIdImpl compareTo(MessageId o) method

Hello, Pulsar community: now when `BatchMessageIdImpl` and `MessageIdImpl` with the same `ledgerId` and `EntryId`, one of it compare with the other, the `BatchMessageIdImpl` will always be greater than MessageIdImpl. see : https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/o

[VOTE] PIP-211: Introduce offload throttling

Dear Pulsar Community, Please review and vote on this PIP. PIP link: https://github.com/apache/pulsar/issues/18004 Discuss thread: https://lists.apache.org/thread/3j8ldw93gyx1kblknygq35nq8g72plpx

[GitHub] [pulsar] crossoverJie added a comment to the discussion: Is it possible to manually acknowledge messages via msgId?

GitHub user crossoverJie added a comment to the discussion: Is it possible to manually acknowledge messages via msgId? > Query `individuallyDeletedMessages` again: > `"individuallyDeletedMessages": "[(414:36..414:39]]",` > The results did not change. I'm sorry, that was my mistake. I was test

[GitHub] [pulsar] crossoverJie edited a comment on the discussion: Is it possible to manually acknowledge messages via msgId?

GitHub user crossoverJie edited a comment on the discussion: Is it possible to manually acknowledge messages via msgId? Thanks for the answer, ~~Before this I thought that `individuallyDeletedMessages` stored unacknowledged messages.~~ --- ~~Here is my testing process:~~ ```java "individual

[DISCUSS] The use of consumer redeliverUnacknowledgedMessages method

Hello, Pulsar community: Now client consumer `void redeliverUnacknowledgedMessages();` is an async interface, but it doesn't have the return value. only `writeAndFlush` the redeliver command then finishes. `ConsumerImpl`: https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/or

Re: [DISCUSS] The use of consumer redeliverUnacknowledgedMessages method

Hi, Congbo. The subscription type is an internal property of the consumer; If two APIs are provided: redeliverUnacknowledgedMessages(only work on shard) and rewind(only work exclusive and failover), This can be confusing for users. Back to the issue, depending on the current usage scenario, the

Re: [ANNOUNCE] New Committer: Cong Zhao

Congrats! Cong > 2022年11月21日 17:56，Jun Ma 写道： > > Congratulations, Cong @coderzc ! > > > From: PengHui Li > Sent: Monday, November 21, 2022 17:13 > To: dev@pulsar.apache.org > Subject: Re: [ANNOUNCE] New Committer: Cong Zhao > > Congrats! Cong > > Thanks, >

[GitHub] [pulsar] Raunak-Agrawal edited a comment on the discussion: Not able to run pulsar function locally

GitHub user Raunak-Agrawal edited a comment on the discussion: Not able to run pulsar function locally @Jason918 @michaeljmarshall can you please help with this? Basically I am trying to run pulsar function with python source code along with some of its external dependencies. I tried to build

[VOTE] Pulsar Release 2.11.0 Candidate 1

This is the third release candidate for Apache Pulsar, version 2.11.0. This release contains 1563 commits by 64 contributors. https://github.com/apache/pulsar/compare/v2.10.2...v2.11.0-candidate-1 CI for this release candidate https://github.com/Technoboy-/pulsar/pull/14 *** Please download, tes

Re: [DISCUSS] The use of consumer redeliverUnacknowledgedMessages method

Hi, Baodi: I don't think it will confuse users, eg. individual ack and cumulative ack, in the share subType cumulative ack have no use. because we have individualAck and cumulativeAck, we should have different redeliver methods for them. I think adding new methods makes sense unless we separate cu

[DISCUSS] PIP-223: Add metrics for all Rest Endpoints

Hi pulsar community, I’ve opened a PIP to discuss: PIP-223: Add metrics for all Rest Endpoints The PIP link: https://github.com/apache/pulsar/issues/18560 Thanks, Tao Jiuming

[GitHub] [pulsar] comradekingu added a comment to the discussion: Archive Crowdin based translation initiative

GitHub user comradekingu added a comment to the discussion: Archive Crowdin based translation initiative Par for the course when using Crowdin. There are no (?) successful libre software translation efforts on Transifex, but there are plenty on Weblate. GitHub link: https://github.com/apache

Re: [Vote] PIP-215: Configurable TopicCompactionStrategy for StrategicTwoPhaseCompactor and TableView

+1 (non-binding) Thanks, Baodi Shi > 2022年11月18日 17:00，Enrico Olivelli 写道： > > +1 (binding) > > Enrico > > Il giorno mar 15 nov 2022 alle ore 02:41 PengHui Li > ha scritto: >> >> +1 >> >> Thanks, >> Penghui >> >> On Wed, Nov 9, 2022 at 12:52 AM Heesung Sohn >> wrote: >> >>> Dear Pulsar

[GitHub] [pulsar] labuladong added a comment to the discussion: Is it possible to manually acknowledge messages via msgId?

GitHub user labuladong added a comment to the discussion: Is it possible to manually acknowledge messages via msgId? For this scenario, this PR https://github.com/apache/pulsar/pull/18263 may help, please take a look. GitHub link: https://github.com/apache/pulsar/discussions/18544#discussion

[GitHub] [pulsar] mattisonchao edited a discussion: Use vert.x-web as our web server

GitHub user mattisonchao edited a discussion: Use vert.x-web as our web server Apache Pulsar is a fully asynchronous system, in the best practice of asynchronous, we can not block any operations and support an excellent way to handle backpressure. Vert.x-web is a good component to be, it sup

Re: Acknowledge contributors for each release

Hi tison, Thanks for raising this up! Expressing appreciation for contributors is a great way to improve health and fitness in our community. Here are just my two cents: 1. Except for the all-contributors list, does it make sense and is it possible to show the top 10 contribut

[GitHub] [pulsar] labuladong edited a comment on the discussion: Is it possible to manually acknowledge messages via msgId?

GitHub user labuladong edited a comment on the discussion: Is it possible to manually acknowledge messages via msgId? For stats of ack holes, this PR https://github.com/apache/pulsar/pull/18263 may help, please take a look. And to handle ack holes, maybe [accumulative ack](https://pulsar.apac

[GitHub] [pulsar] coderzc added a comment to the discussion: Use vert.x-web as our web server

GitHub user coderzc added a comment to the discussion: Use vert.x-web as our web server I think this is a good suggestion. GitHub link: https://github.com/apache/pulsar/discussions/18561#discussioncomment-4200917 This is an automatically sent email for dev@pulsar.apache.org. To unsubscr

Re: [DISCUSS] Release Pulsar Client C++ 3.1.0

+1 Thanks, Yunze On Mon, Nov 21, 2022 at 5:32 PM Zike Yang wrote: > > Hi everyone, > > I would like to propose releasing the Pulsar Client C++ 3.1.0 > > There are several new features and bug fixes in the main branch[0]. > And it’s time to release a new version. > Please remind me if you have an

Re: [DISCUSS] The use of consumer redeliverUnacknowledgedMessages method

Hi, Congbo: Thanks for your explanation. I agree to add a new interface for failover and exclusive subType. >>> I suggest `redeliverUnacknowledgedMessages` be deprecated under >>> failover and exclusive subType and add a new similar async and sync >>> method called `rewind` for failover and excl

Re: [DISCUSS] Release Pulsar Client C++ 3.1.0

+1 Thanks, Baodi Shi > 2022年11月22日 11:07，Yunze Xu 写道： > > +1 > > Thanks, > Yunze > > On Mon, Nov 21, 2022 at 5:32 PM Zike Yang wrote: >> >> Hi everyone, >> >> I would like to propose releasing the Pulsar Client C++ 3.1.0 >> >> There are several new features and bug fixes in the main bran

Re: Acknowledge contributors for each release

To me a contributors list has three levels 1. New contributors whose first PR is included. 2. Contributors who are not yet committers. 3. Committers. As a PMC member I want be on the look out for new committers to grow the Pulsar community. We want the community to see the path to being a commi

[GitHub] [pulsar] nodece added a comment to the discussion: Use vert.x-web as our web server

GitHub user nodece added a comment to the discussion: Use vert.x-web as our web server +1. GitHub link: https://github.com/apache/pulsar/discussions/18561#discussioncomment-4201117 This is an automatically sent email for dev@pulsar.apache.org. To unsubscribe, please send an email to: de

Re: [ANNOUNCE] New Committer: Cong Zhao

Congratulations! Cong Best, Max Xu On Mon, Nov 21, 2022 at 12:10 PM Haiting Jiang wrote: > The Project Management Committee (PMC) for Apache Pulsar has invited > Cong Zhao (https://github.com/coderzc) > to become a committer and we are pleased to announce that he has accepted. > > Being a comm

Re: [ANNOUNCE] New Committer: Cong Zhao

Congrats! Best, tison. Max Xu 于2022年11月22日周二 13:14写道： > Congratulations! Cong > > Best, > Max Xu > > > On Mon, Nov 21, 2022 at 12:10 PM Haiting Jiang > wrote: > > > The Project Management Committee (PMC) for Apache Pulsar has invited > > Cong Zhao (https://github.com/coderzc) > > to become a

Re: [ANNOUNCE] New Committer: Cong Zhao

Congrats! Best, Hang tison 于2022年11月22日周二 13:15写道： > > Congrats! > > Best, > tison. > > > Max Xu 于2022年11月22日周二 13:14写道： > > > Congratulations! Cong > > > > Best, > > Max Xu > > > > > > On Mon, Nov 21, 2022 at 12:10 PM Haiting Jiang > > wrote: > > > > > The Project Management Committee (PMC) f

Re: [ANNOUNCE] New Committer: Cong Zhao

Congrats! Nicolò Boschi Il giorno mar 22 nov 2022 alle ore 06:23 Hang Chen ha scritto: > Congrats! > > Best, > Hang > > tison 于2022年11月22日周二 13:15写道： > > > > Congrats! > > > > Best, > > tison. > > > > > > Max Xu 于2022年11月22日周二 13:14写道： > > > > > Congratulations! Cong > > > > > > Best, > > > M