You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by zhimin li <li...@gmail.com> on 2026/06/16 13:29:09 UTC

[VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Hello RocketMQ Community,
This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
This version introduces the Lite Consumer API and enhances PushConsumer
throughput.

The artifact url:
https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/

The staging repo for maven:
https://repository.apache.org/content/repositories/orgapacherocketmq-1376/

Git tag for the release:
https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1

Hash for the release tag:
471044f0860b90a19f01c4c665c6286455c8f04e

The artifact have been signed with
Key: C9D394D2, which can be found in the
keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS

Key changes since 5.2.0:

- New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
  API with its own builder and subscription manager, providing a simpler
  pull-based consumption model for lite messaging scenarios.

- LitePushConsumer enhancements: added suspend consumption support via
  ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
  processing, plus concurrent consumption via LiteStandardConsumeService
  with local retry on failure.

- Multi-broker subscription sync fix: fixed a bug where
  SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
  The request is now broadcast to all route endpoints with aggregated
  results.

- PushConsumer cache limit increase: raised the max cached message count
  limit for PushConsumer, allowing higher throughput in high-volume
  consumption scenarios.

- Protocol enhancements: updated protos to support producer-side features
  including timed/delayed message recall and priority message sending,
  enabling parity across Java, Go, and C# client SDKs.

Fill in the following:
[+]  check LICENSE, should be Apache V2
[+]  check NOTICE, should have a notice for third-party dependency if
necessary
[+]  extract the zip and check if the source version is correct
[+]  verify the asc(PGP sign),SHA512

The vote will be open for at least 72 hours or until the necessary
number of votes are reached.
Please vote accordingly:
[ ] +1 approve
[ ] +0 no opinion
[ ] -1 disapprove with the reason

Thanks
The Apache RocketMQ Team

Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Posted by Jixiang Jin <ca...@gmail.com>.
+1

> 2026年6月23日 15:16,Rongtong Jin <ji...@mails.ucas.ac.cn> 写道:
> 
> +1
> 
> &quot;zhimin li&quot; &lt;lizhiminx@gmail.com&gt;写道:
>> Hello RocketMQ Community,
>> This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
>> This version introduces the Lite Consumer API and enhances PushConsumer
>> throughput.
>> 
>> The artifact url:
>> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/
>> 
>> The staging repo for maven:
>> https://repository.apache.org/content/repositories/orgapacherocketmq-1376/
>> 
>> Git tag for the release:
>> https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1
>> 
>> Hash for the release tag:
>> 471044f0860b90a19f01c4c665c6286455c8f04e
>> 
>> The artifact have been signed with
>> Key: C9D394D2, which can be found in the
>> keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
>> 
>> Key changes since 5.2.0:
>> 
>> - New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
>>  API with its own builder and subscription manager, providing a simpler
>>  pull-based consumption model for lite messaging scenarios.
>> 
>> - LitePushConsumer enhancements: added suspend consumption support via
>>  ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
>>  processing, plus concurrent consumption via LiteStandardConsumeService
>>  with local retry on failure.
>> 
>> - Multi-broker subscription sync fix: fixed a bug where
>>  SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
>>  The request is now broadcast to all route endpoints with aggregated
>>  results.
>> 
>> - PushConsumer cache limit increase: raised the max cached message count
>>  limit for PushConsumer, allowing higher throughput in high-volume
>>  consumption scenarios.
>> 
>> - Protocol enhancements: updated protos to support producer-side features
>>  including timed/delayed message recall and priority message sending,
>>  enabling parity across Java, Go, and C# client SDKs.
>> 
>> Fill in the following:
>> [+]  check LICENSE, should be Apache V2
>> [+]  check NOTICE, should have a notice for third-party dependency if
>> necessary
>> [+]  extract the zip and check if the source version is correct
>> [+]  verify the asc(PGP sign),SHA512
>> 
>> The vote will be open for at least 72 hours or until the necessary
>> number of votes are reached.
>> Please vote accordingly:
>> [ ] +1 approve
>> [ ] +0 no opinion
>> [ ] -1 disapprove with the reason
>> 
>> Thanks
>> The Apache RocketMQ Team


Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Posted by Jixiang Jin <ca...@gmail.com>.
+1

> 2026年6月23日 15:16,Rongtong Jin <ji...@mails.ucas.ac.cn> 写道:
> 
> +1
> 
> &quot;zhimin li&quot; &lt;lizhiminx@gmail.com&gt;写道:
>> Hello RocketMQ Community,
>> This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
>> This version introduces the Lite Consumer API and enhances PushConsumer
>> throughput.
>> 
>> The artifact url:
>> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/
>> 
>> The staging repo for maven:
>> https://repository.apache.org/content/repositories/orgapacherocketmq-1376/
>> 
>> Git tag for the release:
>> https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1
>> 
>> Hash for the release tag:
>> 471044f0860b90a19f01c4c665c6286455c8f04e
>> 
>> The artifact have been signed with
>> Key: C9D394D2, which can be found in the
>> keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
>> 
>> Key changes since 5.2.0:
>> 
>> - New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
>>  API with its own builder and subscription manager, providing a simpler
>>  pull-based consumption model for lite messaging scenarios.
>> 
>> - LitePushConsumer enhancements: added suspend consumption support via
>>  ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
>>  processing, plus concurrent consumption via LiteStandardConsumeService
>>  with local retry on failure.
>> 
>> - Multi-broker subscription sync fix: fixed a bug where
>>  SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
>>  The request is now broadcast to all route endpoints with aggregated
>>  results.
>> 
>> - PushConsumer cache limit increase: raised the max cached message count
>>  limit for PushConsumer, allowing higher throughput in high-volume
>>  consumption scenarios.
>> 
>> - Protocol enhancements: updated protos to support producer-side features
>>  including timed/delayed message recall and priority message sending,
>>  enabling parity across Java, Go, and C# client SDKs.
>> 
>> Fill in the following:
>> [+]  check LICENSE, should be Apache V2
>> [+]  check NOTICE, should have a notice for third-party dependency if
>> necessary
>> [+]  extract the zip and check if the source version is correct
>> [+]  verify the asc(PGP sign),SHA512
>> 
>> The vote will be open for at least 72 hours or until the necessary
>> number of votes are reached.
>> Please vote accordingly:
>> [ ] +1 approve
>> [ ] +0 no opinion
>> [ ] -1 disapprove with the reason
>> 
>> Thanks
>> The Apache RocketMQ Team


Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Posted by Rongtong Jin <ji...@mails.ucas.ac.cn>.
+1

&quot;zhimin li&quot; &lt;lizhiminx@gmail.com&gt;写道:
> Hello RocketMQ Community,
> This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
> This version introduces the Lite Consumer API and enhances PushConsumer
> throughput.
> 
> The artifact url:
> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/
> 
> The staging repo for maven:
> https://repository.apache.org/content/repositories/orgapacherocketmq-1376/
> 
> Git tag for the release:
> https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1
> 
> Hash for the release tag:
> 471044f0860b90a19f01c4c665c6286455c8f04e
> 
> The artifact have been signed with
> Key: C9D394D2, which can be found in the
> keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
> 
> Key changes since 5.2.0:
> 
> - New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
>   API with its own builder and subscription manager, providing a simpler
>   pull-based consumption model for lite messaging scenarios.
> 
> - LitePushConsumer enhancements: added suspend consumption support via
>   ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
>   processing, plus concurrent consumption via LiteStandardConsumeService
>   with local retry on failure.
> 
> - Multi-broker subscription sync fix: fixed a bug where
>   SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
>   The request is now broadcast to all route endpoints with aggregated
>   results.
> 
> - PushConsumer cache limit increase: raised the max cached message count
>   limit for PushConsumer, allowing higher throughput in high-volume
>   consumption scenarios.
> 
> - Protocol enhancements: updated protos to support producer-side features
>   including timed/delayed message recall and priority message sending,
>   enabling parity across Java, Go, and C# client SDKs.
> 
> Fill in the following:
> [+]  check LICENSE, should be Apache V2
> [+]  check NOTICE, should have a notice for third-party dependency if
> necessary
> [+]  extract the zip and check if the source version is correct
> [+]  verify the asc(PGP sign),SHA512
> 
> The vote will be open for at least 72 hours or until the necessary
> number of votes are reached.
> Please vote accordingly:
> [ ] +1 approve
> [ ] +0 no opinion
> [ ] -1 disapprove with the reason
> 
> Thanks
> The Apache RocketMQ Team

Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Posted by 沈林 <20...@gmail.com>.
+1

m17757106928 <m1...@163.com> 于2026年6月24日周三 11:47写道:

> +1
>
> ---- Replied Message ----
> | From | zhimin li<li...@gmail.com> |
> | Date | 06/16/2026 21:29 |
> | To | dev <de...@rocketmq.apache.org>,
> users <us...@rocketmq.apache.org> |
> | Subject | [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1 |
> Hello RocketMQ Community,
> This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
> This version introduces the Lite Consumer API and enhances PushConsumer
> throughput.
>
> The artifact url:
>
> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/
>
> The staging repo for maven:
> https://repository.apache.org/content/repositories/orgapacherocketmq-1376/
>
> Git tag for the release:
> https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1
>
> Hash for the release tag:
> 471044f0860b90a19f01c4c665c6286455c8f04e
>
> The artifact have been signed with
> Key: C9D394D2, which can be found in the
> keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
>
> Key changes since 5.2.0:
>
> - New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
>  API with its own builder and subscription manager, providing a simpler
>  pull-based consumption model for lite messaging scenarios.
>
> - LitePushConsumer enhancements: added suspend consumption support via
>  ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
>  processing, plus concurrent consumption via LiteStandardConsumeService
>  with local retry on failure.
>
> - Multi-broker subscription sync fix: fixed a bug where
>  SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
>  The request is now broadcast to all route endpoints with aggregated
>  results.
>
> - PushConsumer cache limit increase: raised the max cached message count
>  limit for PushConsumer, allowing higher throughput in high-volume
>  consumption scenarios.
>
> - Protocol enhancements: updated protos to support producer-side features
>  including timed/delayed message recall and priority message sending,
>  enabling parity across Java, Go, and C# client SDKs.
>
> Fill in the following:
> [+]  check LICENSE, should be Apache V2
> [+]  check NOTICE, should have a notice for third-party dependency if
> necessary
> [+]  extract the zip and check if the source version is correct
> [+]  verify the asc(PGP sign),SHA512
>
> The vote will be open for at least 72 hours or until the necessary
> number of votes are reached.
> Please vote accordingly:
> [ ] +1 approve
> [ ] +0 no opinion
> [ ] -1 disapprove with the reason
>
> Thanks
> The Apache RocketMQ Team
>

Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Posted by 沈林 <20...@gmail.com>.
+1

m17757106928 <m1...@163.com> 于2026年6月24日周三 11:47写道:

> +1
>
> ---- Replied Message ----
> | From | zhimin li<li...@gmail.com> |
> | Date | 06/16/2026 21:29 |
> | To | dev <de...@rocketmq.apache.org>,
> users <us...@rocketmq.apache.org> |
> | Subject | [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1 |
> Hello RocketMQ Community,
> This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
> This version introduces the Lite Consumer API and enhances PushConsumer
> throughput.
>
> The artifact url:
>
> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/
>
> The staging repo for maven:
> https://repository.apache.org/content/repositories/orgapacherocketmq-1376/
>
> Git tag for the release:
> https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1
>
> Hash for the release tag:
> 471044f0860b90a19f01c4c665c6286455c8f04e
>
> The artifact have been signed with
> Key: C9D394D2, which can be found in the
> keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
>
> Key changes since 5.2.0:
>
> - New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
>  API with its own builder and subscription manager, providing a simpler
>  pull-based consumption model for lite messaging scenarios.
>
> - LitePushConsumer enhancements: added suspend consumption support via
>  ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
>  processing, plus concurrent consumption via LiteStandardConsumeService
>  with local retry on failure.
>
> - Multi-broker subscription sync fix: fixed a bug where
>  SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
>  The request is now broadcast to all route endpoints with aggregated
>  results.
>
> - PushConsumer cache limit increase: raised the max cached message count
>  limit for PushConsumer, allowing higher throughput in high-volume
>  consumption scenarios.
>
> - Protocol enhancements: updated protos to support producer-side features
>  including timed/delayed message recall and priority message sending,
>  enabling parity across Java, Go, and C# client SDKs.
>
> Fill in the following:
> [+]  check LICENSE, should be Apache V2
> [+]  check NOTICE, should have a notice for third-party dependency if
> necessary
> [+]  extract the zip and check if the source version is correct
> [+]  verify the asc(PGP sign),SHA512
>
> The vote will be open for at least 72 hours or until the necessary
> number of votes are reached.
> Please vote accordingly:
> [ ] +1 approve
> [ ] +0 no opinion
> [ ] -1 disapprove with the reason
>
> Thanks
> The Apache RocketMQ Team
>

Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Posted by m17757106928 <m1...@163.com>.
+1

---- Replied Message ----
| From | zhimin li<li...@gmail.com> |
| Date | 06/16/2026 21:29 |
| To | dev <de...@rocketmq.apache.org>,
users <us...@rocketmq.apache.org> |
| Subject | [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1 |
Hello RocketMQ Community,
This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
This version introduces the Lite Consumer API and enhances PushConsumer
throughput.

The artifact url:
https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/

The staging repo for maven:
https://repository.apache.org/content/repositories/orgapacherocketmq-1376/

Git tag for the release:
https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1

Hash for the release tag:
471044f0860b90a19f01c4c665c6286455c8f04e

The artifact have been signed with
Key: C9D394D2, which can be found in the
keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS

Key changes since 5.2.0:

- New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
 API with its own builder and subscription manager, providing a simpler
 pull-based consumption model for lite messaging scenarios.

- LitePushConsumer enhancements: added suspend consumption support via
 ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
 processing, plus concurrent consumption via LiteStandardConsumeService
 with local retry on failure.

- Multi-broker subscription sync fix: fixed a bug where
 SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
 The request is now broadcast to all route endpoints with aggregated
 results.

- PushConsumer cache limit increase: raised the max cached message count
 limit for PushConsumer, allowing higher throughput in high-volume
 consumption scenarios.

- Protocol enhancements: updated protos to support producer-side features
 including timed/delayed message recall and priority message sending,
 enabling parity across Java, Go, and C# client SDKs.

Fill in the following:
[+]  check LICENSE, should be Apache V2
[+]  check NOTICE, should have a notice for third-party dependency if
necessary
[+]  extract the zip and check if the source version is correct
[+]  verify the asc(PGP sign),SHA512

The vote will be open for at least 72 hours or until the necessary
number of votes are reached.
Please vote accordingly:
[ ] +1 approve
[ ] +0 no opinion
[ ] -1 disapprove with the reason

Thanks
The Apache RocketMQ Team

Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.2.1

Posted by Rongtong Jin <ji...@mails.ucas.ac.cn>.
+1

&quot;zhimin li&quot; &lt;lizhiminx@gmail.com&gt;写道:
> Hello RocketMQ Community,
> This is the vote for gRPC Java Client for Apache RocketMQ 5.2.1.
> This version introduces the Lite Consumer API and enhances PushConsumer
> throughput.
> 
> The artifact url:
> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.2.1-rc1/
> 
> The staging repo for maven:
> https://repository.apache.org/content/repositories/orgapacherocketmq-1376/
> 
> Git tag for the release:
> https://github.com/apache/rocketmq-clients/releases/tag/java-5.2.1
> 
> Hash for the release tag:
> 471044f0860b90a19f01c4c665c6286455c8f04e
> 
> The artifact have been signed with
> Key: C9D394D2, which can be found in the
> keys file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
> 
> Key changes since 5.2.0:
> 
> - New Lite Simple Consumer: introduced a lightweight LiteSimpleConsumer
>   API with its own builder and subscription manager, providing a simpler
>   pull-based consumption model for lite messaging scenarios.
> 
> - LitePushConsumer enhancements: added suspend consumption support via
>   ConsumeResultSuspend type and LiteFifoConsumeService for FIFO-ordered
>   processing, plus concurrent consumption via LiteStandardConsumeService
>   with local retry on failure.
> 
> - Multi-broker subscription sync fix: fixed a bug where
>   SyncLiteSubscriptionRequest was only sent to a single broker endpoint.
>   The request is now broadcast to all route endpoints with aggregated
>   results.
> 
> - PushConsumer cache limit increase: raised the max cached message count
>   limit for PushConsumer, allowing higher throughput in high-volume
>   consumption scenarios.
> 
> - Protocol enhancements: updated protos to support producer-side features
>   including timed/delayed message recall and priority message sending,
>   enabling parity across Java, Go, and C# client SDKs.
> 
> Fill in the following:
> [+]  check LICENSE, should be Apache V2
> [+]  check NOTICE, should have a notice for third-party dependency if
> necessary
> [+]  extract the zip and check if the source version is correct
> [+]  verify the asc(PGP sign),SHA512
> 
> The vote will be open for at least 72 hours or until the necessary
> number of votes are reached.
> Please vote accordingly:
> [ ] +1 approve
> [ ] +0 no opinion
> [ ] -1 disapprove with the reason
> 
> Thanks
> The Apache RocketMQ Team