You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/06/22 06:23:37 UTC
[GitHub] [rocketmq] hyperleoon opened a new issue, #4497: support set subscriptionData with ASSIGN SubscriptionType in DefaultLitePullConsumer
hyperleoon opened a new issue, #4497:
URL: https://github.com/apache/rocketmq/issues/4497
--
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: dev-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] ferrirW commented on issue #4497: Can support set subscriptionData with ASSIGN SubscriptionType in DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
ferrirW commented on issue #4497:
URL: https://github.com/apache/rocketmq/issues/4497#issuecomment-1165568900
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？
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] github-actions[bot] commented on issue #4497: Can support set subscriptionData with ASSIGN SubscriptionType in DefaultLitePullConsumer
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #4497:
URL: https://github.com/apache/rocketmq/issues/4497#issuecomment-1616199326
This issue was closed because it has been inactive for 3 days since being marked as stale.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] hyperleoon commented on issue #4497: Can support set subscriptionData with ASSIGN SubscriptionType in DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] github-actions[bot] commented on issue #4497: Can support set subscriptionData with ASSIGN SubscriptionType in DefaultLitePullConsumer
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #4497:
URL: https://github.com/apache/rocketmq/issues/4497#issuecomment-1612258877
This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] github-actions[bot] closed issue #4497: Can support set subscriptionData with ASSIGN SubscriptionType in DefaultLitePullConsumer
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed issue #4497: Can support set subscriptionData with ASSIGN SubscriptionType in DefaultLitePullConsumer
URL: https://github.com/apache/rocketmq/issues/4497
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org