Ошибка Кафки: процесс Кафки часто прерывается.Показано ниже ошибка при попытке перезапустить это - PullRequest
0 голосов
/ 03 октября 2018

Заранее спасибо.Пожалуйста, помогите мне решить эту ошибку, упомянутую ниже.

00000000000000.txnindex and rebuilding index... (kafka.log.Log)
[2018-09-25 12:48:05,462] ERROR There was an error in one of the threads during logs loading: java.lang.InternalError: a fault occurred in a recent unsafe memory access operation in compiled Java code (kafka.log.LogManager)
[2018-09-25 12:48:05,469] FATAL [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.InternalError: a fault occurred in a recent unsafe memory access operation in compiled Java code
        at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57)
        at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
        at org.apache.kafka.common.record.FileLogInputStream$FileChannelRecordBatch.loadBatchWithSize(FileLogInputStream.java:209)
        at org.apache.kafka.common.record.FileLogInputStream$FileChannelRecordBatch.loadFullBatch(FileLogInputStream.java:192)
        at org.apache.kafka.common.record.FileLogInputStream$FileChannelRecordBatch.ensureValid(FileLogInputStream.java:164)
        at kafka.log.LogSegment$$anonfun$recover$1.apply(LogSegment.scala:263)
        at kafka.log.LogSegment$$anonfun$recover$1.apply(LogSegment.scala:262)
        at scala.collection.Iterator$class.foreach(Iterator.scala:891)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)

1 Ответ

0 голосов
/ 03 октября 2018

Я предполагаю, что в вашем каталоге журналов Kafka (log.dirs в server.properties) недостаточно памяти.Когда Kafka пытается перестроить индекс, недостаточно памяти и, следовательно, посредник Kafka не может быть запущен.Предполагая, что log.dirs=/var/lib/kafka

df -hT /var/lib/kafka 

будет отображать использование памяти для вашего каталога журналов.

...