CM添加kafka服务后出现错误
2016-05-18 10:40
337 查看
如果启动时出现内存溢出错误
Fatal error during KafkaServerStartable startup. Prepare to shutdown java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) at java.nio.ByteBuffer.allocate(ByteBuffer.java:335) at kafka.log.SkimpyOffsetMap.<init>(OffsetMap.scala:43) at kafka.log.LogCleaner$CleanerThread.<init>(LogCleaner.scala:186) at kafka.log.LogCleaner$$anonfun$1.apply(LogCleaner.scala:83) at kafka.log.LogCleaner$$anonfun$1.apply(LogCleaner.scala:83) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) at scala.collection.immutable.Range.foreach(Range.scala:166) at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) at scala.collection.AbstractTraversable.map(Traversable.scala:104) at kafka.log.LogCleaner.<init>(LogCleaner.scala:83) at kafka.log.LogManager.<init>(LogManager.scala:64) at kafka.server.KafkaServer.createLogManager(KafkaServer.scala:601) at kafka.server.KafkaServer.startup(KafkaServer.scala:180) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37) at kafka.Kafka$.main(Kafka.scala:67) at com.cloudera.kafka.wrap.Kafka$.main(Kafka.scala:76) at com.cloudera.kafka.wrap.Kafka.main(Kafka.scala)
在kafka配置中修改Java Heap Size of Broker 512即可。截图如下:
InconsistentBrokerIdException错误:
5月 18, 上午10点20:20.872 FATAL kafka.server.KafkaServerStartable Fatal error during KafkaServerStartable startup. Prepare to shutdown kafka.common.InconsistentBrokerIdException: Configured broker.id 152 doesn't match stored broker.id 113 in meta.properties. If you moved your data, make sure your configured broker.id matches. If you intend to create a new broker, you should remove all data in your data directories (log.dirs). at kafka.server.KafkaServer.getBrokerId(KafkaServer.scala:640) at kafka.server.KafkaServer.startup(KafkaServer.scala:184) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37) at kafka.Kafka$.main(Kafka.scala:67) at com.cloudera.kafka.wrap.Kafka$.main(Kafka.scala:76) at com.cloudera.kafka.wrap.Kafka.main(Kafka.scala)
错误的原因是log.dirs目录下的meta.properties中配置的broker.id和配置目录下的server.properties中的broker.id不一致了,解决问题的方法是将两者修改一致后再重启
相关文章推荐
- Python正则表达式
- android控件上面实现提醒信息(消息数量)
- Textview底部文字被遮挡问题
- 搭建kms服务器速记
- 即时通讯 (环信的重头开始)
- java基础知识:继承
- 深入分析:Android中app之间的交互(二,使用ComponentName)
- 为早期项目添加Ribbon界面
- hive两大表关联优化试验
- Activiti(二)--练习
- 自定义刻度盘View--详解
- 《学习笔记》之JAVA设计模式--简单工厂模式
- 动画Animator
- 关于Java多线程实现生产者和消费者的问题
- 按任意键选择,返回,退出
- 浮动窗口代码(带关闭按钮+全屏漂浮)
- types.MethodType
- R语言基本操作函数(1)变量的基本操作
- linux系统date命令修改时间及hwclock硬件时间
- TextView点击时颜色加深