java - TopologyTestDriver 在位置打开存储时出错

标签 java apache-kafka

我不知道我的项目中的单元测试何时开始失败并出现以下错误:

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/

相关文章:

java - 使用本地镜像测试 URI

java - Android POST 到服务器总是返回错误的响应代码

java - Kafka - 关闭(kafka.server.KafkaServer),启动 Kafka-Server-Start 时出现问题

cassandra - Hbase vs Cassandra vs Kafka 用于高分辨率时间序列数据存储

java - 通过 MSGraph API 创建组也不会创建共享点

java - 部署 jar Tomcat 8

java - Java能改自己控制台的codepage吗?

python - 从 kafka 消费者读取时,如何从用于 avro 记录的架构注册表中查找架构 ID

apache-kafka - 无法使用kafka中的旧消息

apache-kafka - 使用 Apache Kafka 的实际用例