是否可以在运行时将新的状态存储添加到拓扑中

Question

是否有任何方法可以在不关闭KafkaStreams的情况下向拓扑添加新的状态存储并在运行时与处理器连接。

Answer 1

不，我们不能，原因是

使用Kafka Streams时，通常不会直接在代码中创建或实例化状态存储。相反，您可以通过创建一个所谓的StoreBuilder来间接定义状态存储。这个构建器被Kafka Streams用作工厂，在需要的时候和地方在应用程序实例中本地实例化实际的状态存储。