java - Quarkus 有什么方法可以控制来自 Kafka 的 @incomming 消息

Question

我是 quarkus 的新手，我想听一个 kafka 主题，但仅限于某些环境。

   @Incoming("my-topic")
    public void consumeCreation(Record<String, MyClass> record) {
        MyClass teste = record.value();
         
        (more code...)
    }  

我会用这个话题做一些mock，生产环境不想听。有没有办法不基于变量运行@Incoming？

感谢帮助。

Answer 1

该@Incoming方法必须在一个属于 CDI bean 的类中。您可以使用 注释该类@UnlessBuildProfile("prod")，这意味着该 bean 将在prod配置文件中被忽略。

这应该让您控制何时@Incoming使用该方法。（如果不是，那将是一个错误。）

还有一些注释可以让你做类似的事情：

• @IfBuildProfile
• @IfBuildProperty
• @UnlessBuildProperty