liooooo29 opened a new pull request, #1360: URL: https://github.com/apache/rocketmq-clients/pull/1360
### Which Issue(s) This PR Fixes N/A ### Brief Description Port Java's `LiteSimpleConsumer` to the Rust SDK. `LiteSimpleConsumer` provides pull-style consumption of lite topics with reduced overhead. Changes: - Add `LiteSimpleConsumer` and `LiteSimpleConsumerTrait` (`src/lite_simple_consumer.rs`), exported from `src/lib.rs`. - Add `ClientType::LiteSimpleConsumer = 6` (`src/model/common.rs`). - Add lite-topic-aware queue selection for lite consumers (`src/simple_consumer.rs`, `src/util.rs`). - Fix ack/change-invisible-duration to pass through the message's lite topic (`src/client.rs`, `src/model/message.rs`) so acks route to the correct LMQ consume queue. - Add `examples/lite_simple_consumer.rs`. ### How Did You Test This Change? - End-to-end against a RocketMQ proxy (gRPC v2): the producer writes lite messages, `LiteSimpleConsumer` receives them with the correct lite topic and body, and acks them without error. - `cargo fmt` and `cargo clippy` are clean (aside from pre-existing warnings). - `cargo test`: 88 passed; 1 pre-existing, unrelated failure in `session::tests::session_new` (mock-server dependency version mismatch). -- 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]
