我在OEL 8服务器上设置了一个2节点Kafka KRaft集群,详细信息如下:
Kafka版本:kafka_2.13-3.4.0 Java版本:OpenJDK 17
vmhost1:server.properties
process.roles=broker,controller
node.id=1
controller.quorum.voters=1@vmhost1:9093,2@vmhost2:9093
listeners=PLAINTEXT://vmhost1:9092,CONTROLLER://vmhost1:9093
advertised.listeners=PLAINTEXT://vmhost1:9092
字符串
vmhost2:server.properties
process.roles=broker,controller
node.id=2
controller.quorum.voters=1@vmhost1:9093,2@vmhost2:9093
listeners=PLAINTEXT://vmhost2:9092,CONTROLLER://vmhost2:9093
advertised.listeners=PLAINTEXT://vmhost2:9092
ls -la /proc/self/io
-r--------. 1 kafka kafkagrp 0 Nov 10 01:18 /proc/self/io
在启动Kafka服务器时,我遇到了以下错误。
[kafka@vmhost1 kafka_2.13-3.4.0]$ ./bin/kafka-server-start.sh ./config/kraft/server.properties
[2023-11-10 00:56:43,631] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2023-11-10 00:56:43,902] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2023-11-10 00:56:44,041] WARN Unable to update IO metrics (kafka.server.BrokerServer)
java.nio.file.AccessDeniedException: /proc/self/io
at java.base/sun.nio.fs.UnixException.translateToIOException(UnixException.java:90)
at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:106)
at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:111)
at java.base/sun.nio.fs.UnixFileSystemProvider.newByteChannel(UnixFileSystemProvider.java:218)
at java.base/java.nio.file.Files.newByteChannel(Files.java:380)
at java.base/java.nio.file.Files.newByteChannel(Files.java:432)
at java.base/java.nio.file.spi.FileSystemProvider.newInputStream(FileSystemProvider.java:422)
at java.base/java.nio.file.Files.newInputStream(Files.java:160)
at java.base/java.nio.file.Files.newBufferedReader(Files.java:2922)
at java.base/java.nio.file.Files.readAllLines(Files.java:3412)
at java.base/java.nio.file.Files.readAllLines(Files.java:3453)
at kafka.metrics.LinuxIoMetricsCollector.updateValues(LinuxIoMetricsCollector.scala:71)
at kafka.metrics.LinuxIoMetricsCollector.usable(LinuxIoMetricsCollector.scala:91)
at kafka.server.KafkaBroker.$init$(KafkaBroker.scala:106)
at kafka.server.BrokerServer.<init>(BrokerServer.scala:74)
at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:80)
at kafka.Kafka$.buildServer(Kafka.scala:85)
at kafka.Kafka$.main(Kafka.scala:93)
at kafka.Kafka.main(Kafka.scala)
[2023-11-10 00:56:44,050] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
[2023-11-10 00:56:44,053] INFO Starting controller (kafka.server.ControllerServer)
[2023-11-10 00:56:44,064] WARN Unable to update IO metrics (kafka.server.ControllerServer)
java.nio.file.AccessDeniedException: /proc/self/io
at java.base/sun.nio.fs.UnixException.translateToIOException(UnixException.java:90)
at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:106)
at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:111)
at java.base/sun.nio.fs.UnixFileSystemProvider.newByteChannel(UnixFileSystemProvider.java:218)
at java.base/java.nio.file.Files.newByteChannel(Files.java:380)
at java.base/java.nio.file.Files.newByteChannel(Files.java:432)
at java.base/java.nio.file.spi.FileSystemProvider.newInputStream(FileSystemProvider.java:422)
at java.base/java.nio.file.Files.newInputStream(Files.java:160)
at java.base/java.nio.file.Files.newBufferedReader(Files.java:2922)
at java.base/java.nio.file.Files.readAllLines(Files.java:3412)
at java.base/java.nio.file.Files.readAllLines(Files.java:3453)
at kafka.metrics.LinuxIoMetricsCollector.updateValues(LinuxIoMetricsCollector.scala:71)
at kafka.metrics.LinuxIoMetricsCollector.usable(LinuxIoMetricsCollector.scala:91)
at kafka.server.ControllerServer.startup(ControllerServer.scala:142)
at kafka.server.KafkaRaftServer.$anonfun$startup$1(KafkaRaftServer.scala:98)
at kafka.server.KafkaRaftServer.$anonfun$startup$1$adapted(KafkaRaftServer.scala:98)
at scala.Option.foreach(Option.scala:437)
at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:98)
at kafka.Kafka$.main(Kafka.scala:115)
at kafka.Kafka.main(Kafka.scala)
型
我试过更改权限,但即使使用sudo也不允许
chmod 640 /proc/self/io
chmod: changing permissions of ‘/proc/self/io’: Operation not permitted
型
请帮助我解决或一些建议。
1条答案
按热度按时间5m1hhzi41#
“/proc/self”表示“/proc/{pid}”
查看here
因此,chmod命令的“/proc/self”不是Kafka进程的“/proc/self”
确切地说,您更改“/proc/{Kafka process pid}/io”
如果这是一个许可问题,这将得到解决。
可能是另一个问题