Классы-перехватчики#
Общей задачей interceptors служит обработка каждой исходящей/входящей записи на уровне транспорта, до передачи ее в прикладной код. Таким образом, осуществляется независимая от прикладного кода функциональность транспортного слоя.
Вмешательство в работу interceptor со стороны прикладного кода, если interceptor загружен в клиента Kafka, невозможно. Только переинициализация клиента с выгрузкой interceptor.