2016-09-22 3 views
2

Я пишу сообщение в Кафку и потребляю его на другом конце. Выполнение какого-то процесса в нем и запись его на другую тему Кафки.Могу ли я использовать на основе определенных условий в Кафке?

Я хочу знать, какое сообщение ответ на какой запрос ..

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

Для этого подхода нам нужно прочитать каждое сообщение, есть ли какой-либо другой способ, который мы можем использовать на основе условий потребительской конфигурации?

ответ

1

Потребители могут прочитать всю тему. Вы можете пропускать сообщения только через seek(), но нет условий, которые вы можете оценить у брокера для фильтрации сообщений.

Вам нужно будет использовать всю тему процесса/фильтра в клиенте.

+0

Спасибо, Маттиас, мы обработали это разделом. У нас есть три потребителя, которые выливают миллионы рядов в Кафку. теперь мы создали собственных практиков в производстве и потребителе. это уменьшает общую нагрузку. – Aru

+0

Я вижу. Но это не соответствует вашему вопросу. :) В любом случае, рад, что вы нашли способ улучшить ваше приложение! –

Смежные вопросы