Интерсепторы#
Интерсептор (класс-перехватчик) – модуль, который можно подключить к продюсеру и консьюмеру путем указания его класса и настроек в конфигурации продюсера/консьюмера. Перехватчик позволяет выполнить дополнительные функции в определенные моменты процессов отправки и получения сообщений (аналогично срабатыванию по триггеру). Прикладной разработчик может создавать собственные перехватчики с абсолютно любой функциональностью. Можно также подключить цепочку перехватчиков, которые будут выполняться последовательно.
Общей задачей интерсептора служит обработка каждой исходящей/входящей записи на уровне транспорта до передачи ее в прикладной код. Таким образом осуществляется независимая от прикладного кода функциональность транспортного слоя.
Если интерсептор загружен в kafka-клиент, вмешательство в работу интерсептора со стороны прикладного кода невозможно (только переинициализация клиента с выгрузкой перехватчика).
