You are viewing a plain text version of this content. The canonical link for it is here.
Posted to devnull@infra.apache.org by "mushang8923 (GitHub)" <gi...@apache.org> on 2018/08/27 01:15:04 UTC
[GitHub] [rocketmq] mushang8923 opened issue #427: message filter
4.2版本里还能开到filtersrv目录，4.3版本里filtersrv目录已经不见了，通过shell脚本看到的还是启动的FiltersrvStartup,bin目录下所有的exe文件都不见了，是不是有什么改动？
[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org
[GitHub] [rocketmq] mushang8923 commented on issue #427: message
filter
Posted by "mushang8923 (GitHub)" <gi...@apache.org>.
@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 devnull@infra.apache.org
[GitHub] [rocketmq] mushang8923 commented on issue #427: message
filter
Posted by "mushang8923 (GitHub)" <gi...@apache.org>.
@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 devnull@infra.apache.org
[GitHub] [rocketmq] lemonzone2010 commented on issue #427: message
filter
Posted by "lemonzone2010 (GitHub)" <gi...@apache.org>.
> @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 devnull@infra.apache.org
[GitHub] [rocketmq] dongeforever commented on issue #427: message
filter
Posted by "dongeforever (GitHub)" <gi...@apache.org>.
对的，不要配置filterServerNums。
[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org
[GitHub] [rocketmq] vongosling closed issue #427: message filter
Posted by "vongosling (GitHub)" <gi...@apache.org>.
[ issue closed by vongosling ]
[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org
[GitHub] [rocketmq] dongeforever commented on issue #427: message
filter
Posted by "dongeforever (GitHub)" <gi...@apache.org>.
可以用新的过滤特性：https://rocketmq.apache.org/docs/filter-by-sql92-example/
支持SQL表达式过滤。
[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org
[GitHub] [rocketmq] mushang8923 commented on issue #427: message
filter
Posted by "mushang8923 (GitHub)" <gi...@apache.org>.
@dongeforever 配置filterServerNums这种方式根本就不需要了，配置上去就会报错？broker里的filtersrv是不是也不需要了
[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org
[GitHub] [rocketmq] lemonzone2010 commented on issue #427: message
filter
Posted by "lemonzone2010 (GitHub)" <gi...@apache.org>.
> 对的，不要配置filterServerNums。
message filterclass 这种不支持了。消费者中方法也没有去除呀，应该在release note 说明下。
[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org
[GitHub] [rocketmq] vongosling commented on issue #427: message
filter
Posted by "vongosling (GitHub)" <gi...@apache.org>.
目前不支持发布二进制文件以及filtersrc特性。请仔细阅读issue模板，如果有问题，欢迎大家订阅邮件列表然后发邮件到user mail list，http://rocketmq.apache.org/about/contact/
[ Full content available at: https://github.com/apache/rocketmq/issues/427 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org