Quarkus:为什么我需要在application.properties中指定Kafka接收器和源

问题描述

我一直在学习Quarkus,这非常好。我很高兴它与其他东西很好地集成在一起。

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

还有,这是否意味着如果我有一个Quarkus应用程序正在讨论几个不同的主题,而我需要为每个主题配置同步?

我无法判断我是否只是缺少什么,或者指南是否不清楚。

解决方法

指南正确。

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

某些环境中的主题名称可能毫无意义,例如“ abcdefg”,但您可以将渠道名称定义为“价格”。

此外,这意味着您可以在指向相同Kafka主题的同一应用程序/微服务中使用@Outgoing@Incoming,但在配置中使用不同的频道名称。