@dongeforever 
filter sqlConsumer写的有语法错误
  MessageSelector.bySql("(TAGS is not null and TAGS in ('TagA', 'TagB'))" +
                    "and (a is not null and a between 0  3)"));

[ 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