我用的是 cloudera cluster (5.5.1-1.cdh5.5.1)
我安装了 Kafka parcel (2.0.1-1.2.0.1.p0.5)
. 当我尝试在群集上添加kafka服务时,在我尝试添加角色的每个主机上都出现以下错误: Error found before invoking supervisord: User [kafka] does not exist.
我在每个需要的节点上手动创建了用户,重新启动了服务,直到我尝试用cloudera管理器修改kafka配置,它才开始工作。cloudera的Kafka配置并没有“绑定”到真正的Kafka配置。
当我试图修改 broker.id
:
kafkaserverstartable启动期间出现致命错误。准备关闭kafka.common.inconsistentbrokeridexception:配置的broker.id 101与meta.properties中存储的broker.id 145不匹配。如果移动了数据,请确保配置的broker.id匹配。如果您打算创建一个新的代理,您应该删除数据目录(log.dirs)中的所有数据`
暂无答案!
目前还没有任何答案,快来回答吧!