我有一个kafka应用程序配置为使用schema注册表。部署了应用程序的v1,并在拓扑中创建了中间主题的日志(branchchild、reduce state store、jointhis等)。而且,每一个都有一个在模式注册中心注册的模式。
应用程序的v2已准备就绪,但拓扑结构发生了重大变化。部署在与v1相同的主题/拓扑上会导致异常,因为内部主题现在是不正确的。我的“用户”主题保持一致
问题:有没有一种建议的方法来重置应用程序状态,而不是将所有内容吹走并重新读取?删除所有内部状态存储和主题是否有效?kafka streams.cleanup()不会触及注册表,注册表也需要清理。
有人对此有明确的解决方案/建议吗?
暂无答案!
目前还没有任何答案,快来回答吧!