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

Question

有没有办法在不关闭 KafkaStreams 的情况下向拓扑添加新的状态存储并在运行时连接处理器。

Answer 1

不，我们不能，原因是

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