cytnju opened a new issue, #1178:
URL: https://github.com/apache/rocketmq-client-go/issues/1178

   **FEATURE REQUEST**
   
   Pull Consumer support `Assign` subscription type the same to Java SDK
   
   
   ```java
       /**
        * Manually assign a list of message queues to this consumer. This 
interface does not allow for incremental
        * assignment and will replace the previous assignment (if there is one).
        *
        * @param messageQueues Message queues that needs to be assigned.
        */
       void assign(Collection<MessageQueue> messageQueues);
   
   ```
   


-- 
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-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to