• 2024-12-19kafkaui自定义过滤器
    importgroovy.json.JsonSlurper//假设这些变量已经在Groovy上下文中可用//partition,timestampMs,keyAsText,valueAsText,header,key,value//配置要过滤的目标名称deftargetDid=""//JSON解析defjsonSlurper=newJsonSlurper()//假设valueAsText