@Override
                public ConsumerMessageFilter call() throws Exception {
                    ConsumerMessageFilter intanceFilter = ConsumerFilterManager.this.intanceFilter(className);
                    if (intanceFilter != null) {
                        log.warn("Created filter '" + className + "' for group:" + group + " and topic:" + topic);
                    }
                    return intanceFilter;
                }
Consumer filter manager.

@author dennis<killme2008@gmail.com>
metamorphosis-server/src/main/java/com/taobao/metamorphosis/server/filter/ConsumerFilterManager.java