apache kafka

nwnhqdif  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(412)

在windows机器上启动kafka服务器时出现以下错误。我下载了scala 2.11- kafka_2.11-2.1.0.tgz 从链接:https://kafka.apache.org/downloads 我做了以下步骤:
config 文件夹位于 Apache Kafka ( C:\Apache-Kafka\kafka_2.11-2.1.0\config )编辑 “server.properties” 使用任何文本编辑器。
查找 log.dirs 并在 “=/tmp/kafka-logs”C:\Apache-Kafka\kafka_2.11-2.1.0\kafka-logs .
现在只需启动服务器:

>kafka-server-start.bat C:\Apache-Kafka\kafka_2.11-2.1.0\config

错误:

C:\Apache-Kafka\kafka_2.11-2.1.0\bin\windows>kafka-server-start.bat C:\Apache-Kafka\kafka_2.11-2.1.0\config
[2018-12-14 21:09:34,566] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2018-12-14 21:09:34,583] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.nio.file.AccessDeniedException: C:\Apache-Kafka\kafka_2.11-2.1.0\config
        at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83)
        at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
        at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:102)
        at sun.nio.fs.WindowsFileSystemProvider.newByteChannel(WindowsFileSystemProvider.java:230)
        at java.nio.file.Files.newByteChannel(Files.java:361)
        at java.nio.file.Files.newByteChannel(Files.java:407)
        at java.nio.file.spi.FileSystemProvider.newInputStream(FileSystemProvider.java:384)
        at java.nio.file.Files.newInputStream(Files.java:152)
        at org.apache.kafka.common.utils.Utils.loadProps(Utils.java:560)
        at kafka.Kafka$.getPropsFromArgs(Kafka.scala:42)
        at kafka.Kafka$.main(Kafka.scala:58)
        at kafka.Kafka.main(Kafka.scala)

C:\Apache-Kafka\kafka_2.11-2.1.0\bin\windows>

注意:我已经在我的windows机器上安装了apachezookeeper,并且它正在端口上运行 2181 .
我以管理员身份运行命令。

t30tvxxf

t30tvxxf1#

在kafka-server-start.bat之后尝试此操作
使用以下命令:…..\config\server.properties,斜杠在2点之间
我的情况是

vlju58qv

vlju58qv2#

一般来说,我们不能使用c:drive来存储kafka日志。您可以尝试使用c:以外的驱动器来存储kafka日志。它一定有用。
更改kafkahome/config/server.properties中的属性log.dirs={c:}/tmp/kafka以外的驱动器日志。

相关问题