lizhanhui commented on code in PR #4775:
URL: https://github.com/apache/rocketmq/pull/4775#discussion_r940985195
##########
client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java:
##########
@@ -75,6 +75,15 @@ public interface LitePullConsumer {
*/
void assign(Collection<MessageQueue> messageQueues);
+ /**
+ * Set topic subExpression for assign mode. This interface does not allow
be call after start(). Default value is * if not set.
+ * assignment and will replace the previous assignment (if there is one).
+ *
+ * @param subExpression subscription expression.it only support or
operation such as "tag1 || tag2 || tag3" <br> if
+ * * null or * expression,meaning subscribe all
+ */
+ void setSubExpression4Assign(final String topic, final String
subExpression);
Review Comment:
Same here
--
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]
