guyinyou opened a new issue, #989:
URL: https://github.com/apache/rocketmq-clients/issues/989

   ### Before Creating the Enhancement Request
   
   - [x] I have confirmed that this should be classified as an enhancement 
rather than a bug/feature.
   
   
   ### Programming Language of the Client
   
   Go
   
   ### Summary
   
   Propose an enhancement to add PushConsumer functionality to the RocketMQ 
gRPC Go client. The PushConsumer would simplify message consumption logic by 
allowing the client to automatically pull messages from the RocketMQ server and 
deliver them to the application, reducing the need for manual polling.
   
   ### Motivation
   
   The current RocketMQ gRPC Go client primarily relies on the SimpleConsumer 
model, which requires developers to implement complex message polling and 
processing logic. Introducing a PushConsumer can significantly reduce 
development complexity, improve efficiency, and provide a smoother message 
consumption experience. This is particularly important for real-time message 
handling scenarios such as instant messaging applications and real-time data 
analysis.
   
   ### Describe the Solution You'd Like
   
   Implement a PushConsumer interface similar to that of the RocketMQ Java 
client, supporting automatic topic subscription, message filtering, and 
callback handling.
   
   ### Describe Alternatives You've Considered
   
   Continue using SimpleConsumer: While this approach is feasible, it increases 
the burden on developers, especially for applications requiring real-time 
message processing.
   
   ### Additional Context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to