Spring аспект интерфейса прослушивателя Kafka

Я пытаюсь создать аспект и обработать каждую запись, которую мое приложение использовало через Kafka.

Этот метод не работает

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

@Slf4j
@Aspect
@Component
public class Test{

    @Around("execution(* org.springframework.kafka.listener.MessageListener.onMessage(..))")
    public Object onInvoke(ProceedingJoinPoint  joinPoint) throws Throwable {
        log.debug("In aspect");
        Object[] args = joinPoint.getArgs();
       return joinPoint.proceed();
    }
}

Я также пробовал получать записи по аспектам с аннотацией @KafkaListener. Он работает, как и ожидалось, но я также хочу определять имена тем для записей (я использую RetryTopicConfiguration и @KafkaListener(topics = "mainTopic") ).