Mule Kafka Consumer - 模式匹配以过滤消息

Question

我需要在 Mule API 中使用来自 Kafka 主题的消息。发布者将向主题发布数百万条消息。消费者不应该负担获取每个消息并对其所需消息进行过滤的负担。我想知道我们是否可以根据消费者 属性 文件中的任何配置从主题中仅获取匹配特定值的消息？

例如：

Json 发布到主题的消息将是：

{
"OrderId": "XXXXXX",
"Region": "XXX",
"Time":"",
"Date":"",
"Label":"",
"Type":"",
"Comment":"",
...
...
...
}

我只需要从与上面消息中的第二个元素匹配的区域列表中获取消息。

Answer 1

Consumer should not be burdened to fetch each and do filter

我不认为这是可能的。有些东西应该解析消息并进行过滤。这就是流程的作用。