Object kafkaAdvice()

in src/main/java/com/epam/digital/data/platform/excerpt/worker/audit/AuditAspect.java [39:45]


  Object kafkaAdvice(ProceedingJoinPoint joinPoint, Request<ExcerptEventDto> request)
      throws Throwable {
    var signature = (MethodSignature) joinPoint.getSignature();
    var annotation = signature.getMethod().getAnnotation(AuditableListener.class);
    var action = annotation.action();
    return kafkaAuditProcessor.process(joinPoint, action, request);
  }