@@ -0,0 +1,657 @@
+package org.ctrip.ops.sysdev.filters;%0A%0Aimport java.util.Map;%0Aimport java.util.concurrent.ArrayBlockingQueue;%0A%0Aimport com.hubspot.jinjava.Jinjava;%0A%0Apublic class Replace extends BaseFilter %7B%0A%09public Replace(Map config, ArrayBlockingQueue inputQueue) %7B%0A%09%09super(config, inputQueue);%0A%09%7D%0A%0A%09private String src;%0A%09private String value;%0A%09private Jinjava jinjava;%0A%0A%09protected void prepare() %7B%0A%09%09this.src = (String) config.get(%22src%22);%0A%09%09this.value = (String) config.get(%22value%22);%0A%09%09this.jinjava = new Jinjava();%0A%09%7D;%0A%0A%09@Override%0A%09protected void filter(Map event) %7B%0A%09%09if (event.containsKey(this.src)) %7B%0A%09%09%09event.put(this.src, jinjava.render(this.value, event));%0A%09%09%7D%0A%09%7D%0A%7D%0A

add replace filter