Mule Kafka Consumer - шаблон сопоставления для фильтрации сообщений

Question

Мне нужно использовать сообщения от Kafka topi c в Mule API. Издатель собирается опубликовать sh миллионов сообщений в топи c. Потребитель не должен быть обременительным для выборки каждого и выполнять фильтрацию для требуемых сообщений. Я хотел знать, можем ли мы получить только сообщения, соответствующие значениям спецификаций c из топи c на основе каких-либо конфигураций в файле свойств потребителя?

Например:

Json сообщение, опубликованное в topi c будет:

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

Мне нужно получать сообщения только из списка соответствующих регионов второй элемент в сообщении выше.

Answer 1

Потребитель не должен быть обременен, чтобы выбрать каждого и сделать фильтр

Я не верю, что это возможно. Что-то должно разобрать сообщение и выполнить фильтрацию. И это роль потока.