我的设置是：
3个主题：inputtopic、outputtopic和commandtopic。
2个kstream，一个从inputtopic读取，对outputtopic的写入做一些处理。另一个流监听commandtopic，如果出现commandmsg，我希望这个流注册某种类型的回调到处理流。处理流将停止并使用不同的过滤器定义重新初始化（新定义是命令消息中的有效负载）。
我不确定当一个流注册一个回调通知另一个流重新初始化时，是否有一个设计模式可以遵循。我可以想到观察者模式，我可以有一个控制器来管理这两个流，然后命令流可以回调控制器，然后停止并重新初始化处理流。这是正确的方法还是有更好的/推荐的方法来实现这一目标。