我想实现一个方面，以便Kafka从最新的偏移量读取消息。
我想创建和注解如下：

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface MyAnnotation {
}

因此，如果我将这个注解与@kafkalistener方法一起使用，那么这个侦听器应该只从最新的方法读取消息。
我不知道如何为这个场景编写aop。