更改嵌入式Kafka中的zookeeper日志目录

Question

我正在使用spring Kafka的应用程序中设置用于JUnit测试的Embedded-Kafka。为zookeeper日志目录设置的位置/属性是什么。使用Embedded-Kafka时，默认情况下我没有名为server.properties或zookeeper.properties的文件，它会在Windows上的临时文件夹中创建日志文件，但我的临时窗口是有限制的，所以我得到了一个异常

我可以使用以下命令指定Kafka日志目录

@EmbeddedKafka(brokerProperties = { "log.dirs=../kafka-logs/" })

对于我尝试过的代理/zookeeper属性-

 static {
  props.setProperty("java.io.tmpdir", "../kafka-logs/");
}

Answer 1

更改java.io.tmpdir对我来说很好。

../kafka/kafka-1090602028141584277

(../kafka必须已经存在)。

也许您的static块是在创建EmbeddedZookeeper之后调用的？