问题描述
我是 kafka 的新手。我在 server.properties 文件中更改了默认 log.dirs=/tmp/kafka-logs 和 log.dirs=/home/kafka/logs 。当我在 java 中创建流并设置属性时:
prop.put(StreamsConfig.APPLICATION_ID_CONfig,"withinArea-stream");
我收到此错误:
[2021-03-18 17:48:26,505] ERROR Error changing permissions for the state or base directory /tmp/kafka-streams/withinArea-stream (org.apache.kafka.streams.processor.internals.StateDirectory:118)
java.nio.file.NoSuchFileException: /tmp/kafka-streams
at java.base/sun.nio.fs.UnixException.translatetoIOException(UnixException.java:92)
at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:111)
at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:116)
at java.base/sun.nio.fs.UnixFileAttributeViews$Posix.setMode(UnixFileAttributeViews.java:254)
at java.base/sun.nio.fs.UnixFileAttributeViews$Posix.setPermissions(UnixFileAttributeViews.java:276)
at java.base/java.nio.file.Files.setPosixFilePermissions(Files.java:2080)
at org.apache.kafka.streams.processor.internals.StateDirectory.<init>(StateDirectory.java:115)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:745)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:657)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:567)
我没有这个目录,如何解决?提前致谢
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)