0

我一直在将@KafkaListeners 用于必须具有唯一 ID 的那种 Kafka 事件消费者，并且每个事件消费者都必须有一个具有非常特殊名称的单独组。例如：

@KafkaListener(id="AmazingProductEventConsumer",
               topics = "${kafka......topic}",
               clientIdPrefix = "AmazingProductEventConsumerClientId",
               groupId = "${kafka.group.id.prefix}-${environemnt.id}-${application.name}-${kafka.......topic}-#{T(java.util.UUID).randomUUID().toString()}")
public class AmazingProductEventConsumer {
   ... methods...
}

或使用批处理事件侦听器：

public class ProductBatchEventConsumer {

   @KafkaListener(id="ProductBatchEventConsumer ",
               topics = "${kafka......topic}",
               clientIdPrefix = "ProductBatchEventConsumerClientId",
               groupId = "${kafka.group.id.prefix}-${environemnt.id}-${application.name}-${kafka.......topic}-#{T(java.util.UUID).randomUUID().toString()}")
   public void batchEventConsumer(List<Record> records) {
     .... 
   }
}

应用程序非常大，有很多消费者订阅了同一个主题，但一般来说，大约 500-600 个消费者订阅了多个服务中的约 180-200 个主题。我想避免使用样板代码并提取可用于生成这些参数的常见模式，主题和分区除外。

在 Spring Boot 2.2 中，我为此使用了一个单独的 BeanPostProcessor，并在初始化之前生成了需要的字段，并用需要的实例替换了消费者的 KafkaListener 注释，但是在 Spring Boot 2.5.0 中，这个特性不再可用，因为 KafkaListenerAnnotationBeanPostProcessor uses KafkaListener ann = AnnotatedElementUtils.findMergedAnnotation(clazz, KafkaListener.class); 它基于首先声明的注释合成了新的 KafkaListener特性。

我很好奇，是否有任何合法的方式来生成@KafkaListener 的字段id、clientId、groupId和其他可以通过通用模式从其他侦听器中提取的字段。

4

1 回答 1

1

您可以使用更简单的 SpEL。

groupId = "#{@someBean.groupId}"

并将占位符和 UUID 生成getGroupId()放在该 bean 上。

您可以使用带有元注释的自定义注释@KafkaListener和您的道具来避免样板。

或者，如果每个侦听器（UUID 除外）都有其他可变性，请使用

#{@someBean.groupId('${small.property}'})

于 2021-06-01T20:03:03.940 回答