storezhang commented on issue #484:
URL: 
https://github.com/apache/rocketmq-client-go/issues/484#issuecomment-723374344


   > 后来没测试 自己改了 手动改源码 data.ClassFilterMode=true 或者外部再对消息根据tag 过滤一遍 张川 
<[email protected]> 于2020年10月24日周六 下午4:23写道:
   > […](#)
   > 根据示例代码 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过滤无效(在阿里云上) — You are receiving this because you authored the 
thread. Reply to this email directly, view it on GitHub <[#484 
(comment)](https://github.com/apache/rocketmq-client-go/issues/484#issuecomment-715879984)>,
 or unsubscribe 
<https://github.com/notifications/unsubscribe-auth/AA7OXZNS5DWE3M3B25T23R3SMKFGNANCNFSM4M52QHPA>
 .
   
   后面问了一下@skyitachi,将不同的tag改成不同的group,问题解决,不过感觉这样解决不是很好,还是得官方解决这个问题更好


----------------------------------------------------------------
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]


Reply via email to