Object kafkaAdvice()

in src/main/java/com/epam/digital/data/platform/bphistory/persistence/audit/AuditAspect.java [36:40]


  Object kafkaAdvice(ProceedingJoinPoint joinPoint, Object request) throws Throwable {
    var signature = (MethodSignature) joinPoint.getSignature();
    var operation = signature.getMethod().getAnnotation(AuditableService.class).value();
    return kafkaAuditProcessor.process(joinPoint, operation);
  }