我如何扩展spring-kafka的'@KafkaListener‘注解来创建我自己的具有有限属性的注解？

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface LimitedKafkaListener {
    String topic();
    int partition() default 0;
    String groupId() default "";
}

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.listener.MessageListenerContainer;

public class LimitedKafkaListenerAnnotationParser {

    public static KafkaListener parseLimitedKafkaListener(LimitedKafkaListener limitedKafkaListener) {
        String topic = limitedKafkaListener.topic();
        int partition = limitedKafkaListener.partition();
        String groupId = limitedKafkaListener.groupId();

        // 创建一个新的KafkaListener注解，并设置对应的属性值
        KafkaListener kafkaListener = new KafkaListener() {
            @Override
            public String[] topics() {
                return new String[]{topic};
            }

            @Override
            public int containerFactory() {
                return partition;
            }

            @Override
            public String id() {
                return groupId;
            }

            @Override
            public String groupId() {
                return groupId;
            }

            @Override
            public String clientIdPrefix() {
                return "";
            }

            @Override
            public String containerGroup() {
                return "";
            }

            @Override
            public String errorHandler() {
                return "";
            }

            @Override
            public boolean autoStartup() {
                return true;
            }

            @Override
            public Class<? extends MessageListenerContainer>[] containerType() {
                return null;
            }

            @Override
            public String[] topicsPattern() {
                return new String[0];
            }

            @Override
            public String topicPattern() {
                return "";
            }
        };

        return kafkaListener;
    }
}

@LimitedKafkaListener(topic = "my-topic", partition = 0, groupId = "my-group")
public void handleMessage(String message) {
    // 处理消息的逻辑
}