Quarkus：为什么我需要在 application.properties 中指定 Kafka sink 和 sources

Question

我一直在学习 Quarkus，它非常好。我很高兴它与其他东西很好地结合在一起。

我一直在遵循本指南 (https://quarkus.io/guides/kafka) 将 Quarkus 与 Apache Kafka 结合使用，我对为什么我们需要指定接收器和源“端点”感到有点恼火？ application.properties 文件中的“频道”。这些只是代码中的内容的重复吗？也许我在这里不理解某些东西，但我认为不需要配置这些真的很好。

此外，这是否意味着如果我的 Quarkus 应用涉及多个不同的主题，我需要为每个主题配置同步？

我不知道是我遗漏了什么，还是指南不清楚。

Answer 1

指南正确。

原因是 Kafka 主题名称可能与 @Incoming 或 @Outgoing 上的频道名称不同。

有些环境可能会有无意义的主题名称，例如“abcdefg”，但您可以将频道名称定义为“价格”。

此外，这意味着您可以在相同的 application/microservice 中使用 @Outgoing 和 @Incoming 指向相同的 Kafka 主题，但在配置中使用不同的通道名称。