Kafka 连接过滤变压器

Question

我正在使用 Kafka-connect，我想过滤掉一些消息。

这就是 Kafka 中单个消息的样子。

{
  "code": 2001,
  "time": 11111111,
  "requestId": "123456789",
  "info": [
    {
      "name": "dan",
      "value": 21
    }
  ]
}

这就是我的变压器的样子

transforms:
  transforms: FilterByCode
  transforms.FilterByCode.type: io.confluent.connect.transforms.Filter$Value
  transforms.FilterByCode.filter.condition: $[?(@.code == 2000)]
  transforms.FilterByCode.filter.type: include

我想过滤掉code值不是2000的消息。我尝试了几种不同的条件语法，但找不到任何有效的语法。所有的消息都被转换，没有一个被过滤。

关于我应该如何使用过滤条件的语法有什么想法吗？

Answer 1

如果您想过滤掉所有非 2000 代码，请尝试 [?(@.code != 2000)] 你可以在这里测试 - http://jsonpath.herokuapp.com/

Kafka 连接过滤变压器

Kafka Connect Filter Transformer

apache-kafka

apache-kafka-connect