Я получаю ошибку ниже. Я пытаюсь запустить встроенную кафку для scala функционального теста. Но получаю ошибку ниже.
[ScalaTest-run-running-SparkJonIntegrationTest] ERROR kafka.server.LogDirFailureChannel - Failed to create or validate data directory /var/folders/m_/kdrdgmlj5j5bh_hbkqwvzvrc0000gp/T/kafka-logs1975502817769156037.tmp
java.io.IOException: Failed to load /var/folders/m_/kdrdgmlj5j5bh_hbkqwvzvrc0000gp/T/kafka-logs1975502817769156037.tmp during broker startup
at kafka.log.LogManager$$anonfun$createAndValidateLogDirs$1.apply(LogManager.scala:152)
at kafka.log.LogManager$$anonfun$createAndValidateLogDirs$1.apply(LogManager.scala:149)