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

Question

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

例如：

Json 消息发布到主题将是：

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

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

Answer 1

消费者不应该承担获取每个过滤器的负担

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