Я хочу реализовать Aspect, чтобы Кафка читал сообщение с последнего смещения.
Я хочу создать аннотацию, как показано ниже:
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface MyAnnotation {
}
Так что, если я буду использовать эту аннотацию слюбой метод @KafkaListener, тогда этот слушатель должен читать сообщения только из самого последнего.
Я не знаю, как написать AOP для этого сценария.