使用SpringAOP截获kafka轮询请求

@Aspect
public class KafkaPollAspect {
    
    @Pointcut("execution(* org.apache.kafka.clients.consumer.KafkaConsumer.poll(..))")
    public void kafkaPollPointcut() {}
    
    @Before("kafkaPollPointcut()")
    public void beforeKafkaPoll(JoinPoint joinPoint) {
        // 在目标方法执行前执行的逻辑
        System.out.println("Before Kafka poll");
    }
    
    @After("kafkaPollPointcut()")
    public void afterKafkaPoll(JoinPoint joinPoint) {
        // 在目标方法执行后执行的逻辑
        System.out.println("After Kafka poll");
    }
}

<aop:aspectj-autoproxy />

<bean id="kafkaPollAspect" class="com.example.KafkaPollAspect" />

@Component
public class KafkaConsumerService {
    
    @Autowired
    private KafkaConsumer<String, String> kafkaConsumer;
    
    public void consumeMessages() {
        // 消费消息的逻辑
        kafkaConsumer.poll(Duration.ofMillis(100));
    }
}