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