@dongeforever 
filter sqlConsumer写的有语法错误
  MessageSelector.bySql("(TAGS is not null and TAGS in ('TagA', 'TagB'))" +
                    "and (a is not null and a between 0  3)"));
要用这个sqlfilter还要增加配置enablePropertyFilter=true 吧

[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to