频道栏目
首页 > 网络 > 云计算 > 正文

Kafka使用ambari安装是常见问题解决方法

2018-06-12 10:09:51      个评论    来源:li-break  
收藏   我要投稿

错误1:kafka.common.InconsistentBrokerIdException: Configured brokerId 1 doesn’t match stored brokerId 0 in meta.properties

[2016-06-2915:05:29,127] FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.common.InconsistentBrokerIdException: Configured brokerId 1 doesn't match stored brokerId 0in meta.properties at kafka.server.KafkaServer.getBrokerId(KafkaServer.scala:630) at kafka.server.KafkaServer.startup(KafkaServer.scala:175) at io.confluent.support.metrics.SupportedServerStartable.startup(SupportedServerStartable.java:99) at io.confluent.support.metrics.SupportedKafka.main(SupportedKafka.java:45)

解决方案:

$KAFKA_HOME/conf/server.properties文件里的属性值log.dirs=/storage/kafka-logs,进入/storage/kafka-logs(具体看log.dirs后面的值)目录,修改meta.properties文件

源文件

version=0

broker.id=0

修改后(修改broker.id为当前节点的broker.id)

version=0

broker.id=1

错误2 : ambari安装Kafka后其他节点使用broker的IP无法访问

ambari安装Kafka后,管理页面看到的配置是

\

在broker节点上看到的配置是【管理页面配置的localhost会自动映射为当前节点的主机名】

\

然后用JAVA代码生产、消费Kafka,报错

\

具体原因:

\

解决方案:分别修改每个broker的$KAFKA_HOME/conf/server.properties文件,属性

\
主机名改成IP。

注意:修改配置文件后,只能手动从每个节点启动kafka,如果使用ambari启动,上述修改会恢复成之前的结果。

上一篇:大数据技术之sbt安装教程
下一篇:最后一页
相关文章
图文推荐

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站