java Kafka集群启动警告|无法更新IO指标|异常:/proc/self/io

vsdwdz23  于 7个月前  发布在  Java
关注(0)|答案(1)|浏览(69)

我在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


请帮助我解决或一些建议。

5m1hhzi4

5m1hhzi41#

“/proc/self”表示“/proc/{pid}”
查看here
因此,chmod命令的“/proc/self”不是Kafka进程的“/proc/self”
确切地说,您更改“/proc/{Kafka process pid}/io”
如果这是一个许可问题,这将得到解决。
可能是另一个问题

相关问题