hyperleoon commented on issue #4497: URL: https://github.com/apache/rocketmq/issues/4497#issuecomment-1168119291
> Current SusscriptionType will be auto set when user call [DefaultLitePullConsumer.assign() ](https://github.com/apache/rocketmq/blob/316d32a006ea49ed806aa965890c917020c426c2/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java#L269) > > does this solve your problem? Our business scenario requires a preview of the five most recent or earliest messages for a certain tag under a certain topic. So I try to use` org.apache.rocketmq.client.consumer.DefaultLitePullConsumer#seekToBegin` and `org.apache.rocketmq.client.consumer. DefaultLitePullConsumer#seek` api , but `seek` doesn't seem to work with `org.apache.rocketmq.client.consumer.LitePullConsumer#subscrib`e, resulting in the inability to customize subExpression. I tried to rewrite `org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl#assign` to support custom subExpressions under ASSIGN SubscriptionType:  This seems to work.But I'm not sure if this causes other problems and why it's not natively supported. -- 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]
