maqingxiang opened a new issue #711:
URL: https://github.com/apache/rocketmq-client-go/issues/711
BUG REPORT
// push_consumer.go
func (pc *DefaultPushConsumer) Unsubscribe(topic string) error {
...
retryTopic := internal.GetRetryTopic(pc.consumerGroup)
pc.subscriptionDataTable.Delete(retryTopic)
...
}
There's a scene where the same ConsumerGroup subscries to T1, subscries to
T2, and unsubscribe T1. Is that a problem?
the client version is github.com/apache/rocketmq-client-go/v2 v2.1.0
--
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]
