此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.9！spring-doc.cadn.net.cn

@KafkaListener属性修改

从版本 2.7.2 开始，您现在可以在创建容器之前以编程方式修改注释属性。为此，请添加一个或多个KafkaListenerAnnotationBeanPostProcessor.AnnotationEnhancer到应用程序上下文。AnnotationEnhancer是一个BiFunction<Map<String, Object>, AnnotatedElement, Map<String, Object>并且必须返回属性映射。属性值可以包含 SpEL 和/或属性占位符;在执行任何解析之前调用增强器。如果存在多个增强器，并且它们实现Ordered，它们将按顺序被调用。spring-doc.cadn.net.cn

AnnotationEnhancer必须声明 bean 定义static因为它们在应用程序上下文的生命周期中非常早期就需要。

示例如下：spring-doc.cadn.net.cn

@Bean
public static AnnotationEnhancer groupIdEnhancer() {
    return (attrs, element) -> {
        attrs.put("groupId", attrs.get("id") + "." + (element instanceof Class
                ? ((Class<?>) element).getSimpleName()
                : ((Method) element).getDeclaringClass().getSimpleName()
                        +  "." + ((Method) element).getName()));
        return attrs;
    };
}