我不知道我的项目中的单元测试何时开始失败并出现以下错误:
ProcessorStateException: Error opening store myStore at location aLocation
此异常是由 TopologyTestDriver 构造函数生成的。
最佳答案
经过多次尝试,我发现进入 TopologyTestDriver 的属性与部署中的属性不同,因此我必须进行调整:
streamProperties.put(StreamsConfig.STATE_DIR_CONFIG, "my/desired/path");
添加此配置后,一切正常。
关于java - TopologyTestDriver 在位置打开存储时出错,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60375697/