Transformaty źródłowe

c = create u = update d = delete r = read (applies to only snapshots) t = truncate m = message

Filtrowanie operacji UPDATE

{
  "transforms": "filter",
  "transforms.filter.type": "io.debezium.transforms.Filter",
  "transforms.filter.language": "jsr223.groovy",
  "transforms.filter.condition": "value.op == 'u' || value.op == 'r'"
}

Filtrowanie operacji INSERT

{
  "transforms": "filter",
  "transforms.filter.type": "io.debezium.transforms.Filter",
  "transforms.filter.language": "jsr223.groovy",
  "transforms.filter.condition": "value.op == 'c' || value.op == 'r'"
}

Filtrowanie operacji DELETE

{
  "transforms": "filter",
  "transforms.filter.type": "io.debezium.transforms.Filter",
  "transforms.filter.language": "jsr223.groovy",
  "transforms.filter.condition": "value.op == 'd' || value.op == 'r'"
}

Filtrowanie operacji z warunkiem po wartościach

{
  "transforms": "filter",
  "transforms.filter.type": "io.debezium.transforms.Filter",
  "transforms.filter.language": "jsr223.groovy",
  "transforms.filter.condition": "value.op == 'r' || (value.op == 'u' && value.before.company=='XYZMobile')"
}