kafka Corrupt index found
2015-07-15 00:00
183 查看
错误
java.lang.IllegalArgumentException: requirement failed: Corrupt index found, index file (/home/sca_bj/jade/kafka_2.9.2-0.8.2.1/kafka-logs/test-0/00000000000000000009.index) has non-zero size but the last offset is 9 and the base offset is 9
at scala.Predef$.require(Predef.scala:214)
at kafka.log.OffsetIndex.sanityCheck(OffsetIndex.scala:352)
at kafka.log.Log$$anonfun$loadSegments$5.apply(Log.scala:184)
at kafka.log.Log$$anonfun$loadSegments$5.apply(Log.scala:183)
at scala.collection.Iterator$class.foreach(Iterator.scala:772)
at scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:573)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:73)
at scala.collection.JavaConversions$JCollectionWrapper.foreach(JavaConversions.scala:592)
at kafka.log.Log.loadSegments(Log.scala:183)
at kafka.log.Log.<init>(Log.scala:67)
at kafka.log.LogManager$$anonfun$loadLogs$2$$anonfun$3$$anonfun$apply$7$$anonfun$apply$1.apply$mcV$sp(LogManager.scala:142)
at kafka.utils.Utils$$anon$1.run(Utils.scala:54)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2015-07-15 16:07:35,904] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer)
解决办法:
find kafka-logs/ -size 10485760c -name *.index #-delete
执行命令 把查到的文件都删掉
具体为啥不解释
java.lang.IllegalArgumentException: requirement failed: Corrupt index found, index file (/home/sca_bj/jade/kafka_2.9.2-0.8.2.1/kafka-logs/test-0/00000000000000000009.index) has non-zero size but the last offset is 9 and the base offset is 9
at scala.Predef$.require(Predef.scala:214)
at kafka.log.OffsetIndex.sanityCheck(OffsetIndex.scala:352)
at kafka.log.Log$$anonfun$loadSegments$5.apply(Log.scala:184)
at kafka.log.Log$$anonfun$loadSegments$5.apply(Log.scala:183)
at scala.collection.Iterator$class.foreach(Iterator.scala:772)
at scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:573)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:73)
at scala.collection.JavaConversions$JCollectionWrapper.foreach(JavaConversions.scala:592)
at kafka.log.Log.loadSegments(Log.scala:183)
at kafka.log.Log.<init>(Log.scala:67)
at kafka.log.LogManager$$anonfun$loadLogs$2$$anonfun$3$$anonfun$apply$7$$anonfun$apply$1.apply$mcV$sp(LogManager.scala:142)
at kafka.utils.Utils$$anon$1.run(Utils.scala:54)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2015-07-15 16:07:35,904] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer)
解决办法:
find kafka-logs/ -size 10485760c -name *.index #-delete
执行命令 把查到的文件都删掉
具体为啥不解释
相关文章推荐
- 入职感悟!
- String新用
- Highcharts-ng 设置spline的legend symbol 样式为正方形
- junit测试jndi的程序
- Memcached基础知识
- php项目如何自定义404页面
- golang web 自定义Handler时候静态资源问题
- 使用shell分页读取600万+的MySQL数据脚本
- php的memcache和memcached扩展区别
- KVM的shutdown命令不管用解决办法
- 大型网站架构演化
- iOS阶段学习第21天笔记(ARC内存管理-Copy-代理)
- 给Android程序员的六个建议
- 【leetcode】Kth Smallest Element in a BST
- Color To String
- Resharp非常实用的快捷键
- C语言中的指针与字符串
- c语言中的指针与数组
- 使用IntrospectorCleanupListener 解决quartz引起的内存泄漏
- MouseListener与MouseAdapter的区别