Apache kafka, использующий динамический pv (nfs) в kubernetes, ошибка диска при блокировке каталога - PullRequest
Новая
       29

Apache kafka, использующий динамический pv (nfs) в kubernetes, ошибка диска при блокировке каталога

0 голосов
/ 16 апреля 2019

Нет проблем при первой установке cp-helm-chart. кафка, кафка-коннект, схема ... все отлично работает. Но я получаю эту ошибку, когда экземпляры Кафки перезапускаются. Как мы можем решить эту проблему?

Прерванная Кафка заблокировала файловую систему.

Я использую сервер NFS. 

 [2019-04-15 09:19:43,118] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-04-15 09:19:43,180] ERROR Disk error while locking directory /opt/kafka/data-0/logs (kafka.server.LogDirFailureChannel)
java.nio.file.FileSystemException: /opt/kafka/data-0/logs/.lock: Invalid argument
    at sun.nio.fs.UnixException.translateToIOException(UnixException.java:91)
    at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
    at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
    at sun.nio.fs.UnixFileSystemProvider.newFileChannel(UnixFileSystemProvider.java:177)
    at java.nio.channels.FileChannel.open(FileChannel.java:287)
    at java.nio.channels.FileChannel.open(FileChannel.java:335)
    at kafka.utils.FileLock.<init>(FileLock.scala:30)
    at kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:238)
    at kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:236)
    at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
    at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
    at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
    at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
...