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

   ## Feature Request
   
   The Rust SDK currently only has `LitePushConsumer` (push-style lite 
consumption, added in #1227). It is missing `LiteSimpleConsumer` (pull-style 
lite consumption).
   
   Java (#1188) and Go (#1314) already implement `LiteSimpleConsumer`. This 
issue tracks adding it to the Rust SDK so all languages reach parity for lite 
pull consumption.
   
   ## Proposal
   
   - Add `LiteSimpleConsumer` and `LiteSimpleConsumerTrait`.
   - Add `ClientType::LiteSimpleConsumer = 6`.
   - Add lite-topic-aware queue selection for lite consumers.
   - Fix ack/change-invisible-duration to pass through the message's lite topic 
so acks route to the correct LMQ consume queue.
   - Add an example (`examples/lite_simple_consumer.rs`).
   


-- 
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