我如何获得两个具有相同分区键的主题，而分区数在kafka流应用程序中属于同一使用者？

Question

我正在尝试在其中创建Kafka Streams服务

1. 我正在尝试初始化处理器中的缓存，然后将通过使用主题为“ nodeStateChanged”的消息来更新分区键的位置ID，以进行更新。

2. 当我使用另一个主题时，我需要检查节点状态，让我们再次说“ Report”（由相同的locationId键控）。实际上，我正在加入由nodeStateChanged创建的表。

我如何确保nodeStateChanged的所有更新都与Report主题位于同一实例上，以便在收到新报告时可以查找位置。需要通过相同的拓扑创建1和2，或者可以创建共享相同的APPLICATION_ID_CONFIG的两个单独的拓扑。

Answer 1

您无需执行任何操作。 Kafka Streams将

always