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

Question

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

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

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

感谢您的帮助。

Answer 1

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

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

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

@IfBuildProfile
@IfBuildProperty
@UnlessBuildProperty

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

Is there any way in Quarkus to control the @incomming message from Kafka

java

apache-kafka

quarkus

smallrye-reactive-messaging