storezhang commented on issue #484:
URL:
https://github.com/apache/rocketmq-client-go/issues/484#issuecomment-715879984
> 根据示例代码
> `selector := consumer.MessageSelector{ Type: consumer.TAG, Expression:
"TagA || TagC", } err := c.Subscribe("TopicTest", selector, func(ctx
context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)
{ fmt.Printf("subscribe callback: %v \n", msgs) return consumer.ConsumeSuccess,
nil }) `
> 设置TAG过滤条件不起作用
> 消费的时候对selector 有 条件校验 `if data.Tags.Len() > 0 && data.ClassFilterMode {`
> 但是没有代码设置ClassFilterMode为true
你解决了吗？我也是tag过滤无效（在阿里云上）
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
