给定一个可以有多个示例的组件和以下结构：1.流1 [主题1，目标1]1.流2 [主题2，目标2]其中目的地是一个 * 队列 *，所有链接都是1：1。是否需要为每个KafkaStream设置相同的applicationId？众所周知，applicationId将生成client.id和group.id，这两个值对于分区的分配方式非常重要。在官方文档中找不到任何内容。
gt0wga4j1#
您可以在同一个JVM进程中运行两个应用程序，并使用单独的线程来启动两个拓扑，也可以只运行两个独立的JVM进程。这两种情况都使用不同的id。或者，您可以运行一个进程（一个id），订阅两个主题，但使用branch操作符按主题名称分隔流。
branch
1条答案
按热度按时间gt0wga4j1#
您可以在同一个JVM进程中运行两个应用程序，并使用单独的线程来启动两个拓扑，也可以只运行两个独立的JVM进程。这两种情况都使用不同的id。
或者，您可以运行一个进程（一个id），订阅两个主题，但使用
branch操作符按主题名称分隔流。