kafkaui自定义过滤器

import groovy.json.JsonSlurper// 假设这些变量已经在 Groovy 上下文中可用
// partition, timestampMs, keyAsText, valueAsText, header, key, value// 配置要过滤的目标名称
def targetDid = ""// JSON 解析
def jsonSlurper = new JsonSlurper()// 假设 valueAsText 包含完整的 JSON 数据
def valueJson = valueAsText ? jsonSlurper.parseText(valueAsText) : null// 过滤结果
def result = false// 检查 request_body[json格式字符串] 是否存在并解析
if (valueJson && valueJson.request_body) {// 解析 request_bodydef requestBody = jsonSlurper.parseText(valueJson.request_body)// 检查 name 是否等于目标名称if (requestBody.did == targetName) {result = true}
}// 返回过滤结果
return result