Java quarkus kafka 从配置文件设置主题名称

发布于04月27日

当我想要配置客户并指定主题的名称时，不可能从配置中指定该名称，例如，这是使用Spring完成的

Quarkus:

@ApplicationScoped
public class Consumer {
    
    @Incoming("topic-name")  //is it possible to pass the value from the config here?
    public void consume(String s) {
        Log.info(s);
    }
}

在春天，它会是这样的

@Incoming("${topic.name}")

Application.yml

topic:
   name: topic-name

是否可以将值从配置传输到Quarkus中的@Incoming("value")注释？

推荐答案

您必须在@Income注释中提供‘频道名称’，而不是‘主题名称’.

您的Java代码将如下所示:

@ApplicationScoped
public class Consumer {

   @Incoming("your-custom-channel-name")
   public void consume(String s) {
      Log.info(s);
   }
}

老实说，我从来没有使用过YML格式，只使用过Application.Properties文件.在这里，您将使用频道的每个属性定义频道(如主题):

mp.messaging.incoming.your-custom-channel-name.topic=your-topic-name
mp.messaging.incoming.your-custom-channel-name.auto.offset.reset=earliest
mp.messaging.incoming.your-custom-channel-name.group.id=${quarkus.kafka-streams.application-id}-my-private-group-id

我假设，如果您try 将其重新格式化为您的YML文件，它将如下所示(未经过测试):

mp:
  messaging:
    incoming: 
      your-custom-channel-name:
        topic: your-topic-name
        auto:
          offset:
            reset: earliest
        group:
          id: ${quarkus.kafka-streams.application-id}-my-private-group-id

按照Quarkus网站上的此指南，您可以逐步了解如何做到这一点:Reactive messaging with Kafka