1

我正在玩 Quarkus，我正在尝试创建摄取服务，它将数据发送到 kafka 或另一个 REST 端点。我在项目中添加了“quarkus-smallrye-reactive-messaging-kafka”和“quarkus-reactive-messaging-http”依赖项。我希望一次只有一个特定的管道，即 http->kafka 或 http->http，但我应该能够使用配置更新然后重新启动来更改它。我可以通过添加 2 个依赖项和配置来实现这一点，如下所示

## Rest service configuration
mp.messaging.outgoing.messages.connector=smallrye-http
mp.messaging.outgoing.messages.method=POST
mp.messaging.outgoing.messages.url=http://localhost:9009/messages

## Kafka Ingestion configuration
## ----------------------------
#mp.messaging.outgoing.messages.connector=smallrye-kafka
#kafka.bootstrap.servers=host.docker.internal:9092
#mp.messaging.outgoing.messages.topic=messages
#mp.messaging.outgoing.messages.value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer

现在的问题是，即使我在 application.propertues 中注释掉了 Kafka 连接器，Kafka 的运行状况检查仍然运行并显示 Kafka 已关闭。我希望它不应该运行 Kafka 健康检查，因为我没有按照配置进行配置。现在这可能吗？如果没有，将其视为功能请求并包含它是否有意义？

问候，

4

1 回答 1

1

默认情况下禁用 Kafka 的健康检查。

但是响应式消息的健康检查默认是启用的，你可以通过mp.messaging.outgoing.messages.heath-enabled=false.

请注意，对于您的用例，您还可以使用不同的通道并禁用您未使用的通道，而不是注释掉配置。

可以通过简单地禁用通道mp.messaging.outgoing.messages.enabled=false。

于 2021-02-25T08:06:12.403 回答