问题描述

开发环境的一个老kafka集群,集群所在机器的一个节点磁盘被占满了导致broker节点挂掉了,进行重新启动时,报错:org.apache.zookeeper.KeeperException$NoAuthException:=Noauth for/consumers

原因分析

由于这个kafka集群是一个老集群,并且是没有鉴权认证的,此时居然报了一个没有权限的错误,给我都干懵了… 不过问题还是要看的,于是乎,进入后台看了一下集群的配置文件,发现kafka集群确实是不带鉴权,但是kafka和zk之间是带鉴权的… 真是让人很无语的操作,至今我也不是很明白,kakfa如果对外没有鉴权,单单和zk之间有鉴权的优势在哪…
好了,废话不在多说,当发现kafka和zk之间有鉴权,那么没啥说的,先去查一下此目录的权限啊:getAcl /consumers,结果发现是’world,'anyone cdrwa 也就是说没有权限方面的限制
然后更奇怪的事情发生了…将另外一个节点主动停掉后,在重新启动,然后发现也起不来了,报同样的错,这就难办了呀,正常在用的节点重启都起不来了,这着实让人懵逼,不过话又说回来了,咱不就是干这个的么,继续排查吧!
然后经过一番痛苦的排查+度娘+询问大神(此处省略一天的崩溃排查原因时间,详情就不好多说了),甚至中间将整个集群所有节点服务(包括zk节点和broker节点)全都停止掉(因为是开发环境嘛)然后发现所有停掉的服务zk节点能启动,broker节点启动就报错没权限,最后发现,zk节点启动的时候读的权限配置文件,是另外一个kakfa集群的(带鉴权)(两个集群在同样的机器上以不同的端口部署的),于是对比排查了一下zookeeper-server-start脚本,发现KAFKA_OPTS变量配置的路径也没有问题,这就奇怪了,路径配置都没有问题,怎么会读到别的配置上去了呢?由此就想到(当然不是第一时间想到的…)是不是linux环境有啥问题,然后查看了一下profile,果然,KAFKA_OPTS被配成了环境变量,值是另外一个带鉴权的鉴权配置文件的路径,启动zk和启动broker都需要此变量配的鉴权文件路径,而且一般来说是两个不同的鉴权配置文件,如果配置成linux环境变量,肯定会导致启动zk和启动broker时读取同一个文件,况且,实际环境中,还搭建了两套kafka集群…(对于此骚操作,表示******),

解决方案

将被设置成环境变量的KAFKA_OPTS取消设置(unset),然后这样启动时就能读取脚本中配置的路径了,启动zk,启动broker,集群恢复!

思考

kafka集群搭建中,如果资源允许,最好是集群独占机器,并且最好按照一定的规范去操作,不然时间久了,环境乱七八糟的了,可能连自己一时间也找不出问题在哪了

【记一次kafka启动报org.apache.zookeeper.KeeperException$NoAuthException:=Noauth for/consumers】相关推荐

  1. Kafka 启动报错 AccessDeniedException

    Kafka 启动报错 AccessDeniedException 今天在本地电脑window环境上下载kafka,启动zookeeper正常,启动kafka时报:java.nio.file.Acces ...

  2. kafka启动报错Java HotSpotTM 64-bit Server VM warning:INFO: os::commit_memory

    版权声明:版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/qq_39501726/article/details/81938695 kafka启动报错 ...

  3. 【kafka】kafka 启动报错 InvalidReceiveException: Invalid receive (size = -720899)

    1.概述 kafka启动报错InvalidReceiveException: Invalid receive (size = -720899) 参考文章:https://bbs.csdn.net/to ...

  4. org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /nb-conf

    2019独角兽企业重金招聘Python工程师标准>>> 异常信息 2018-05-21 18:38:05.851 ERROR 18796 --- [nio-8082-exec-4] ...

  5. 服务器上Kafka启动报错:error=‘Cannot allocate memory‘ (errno=12)

    文章目录 环境 经历如下弯路才查看到报错信息 解决方法 1.kill一些不用的进程,来腾出内存. 2.修改默认配置,减少软件启动需要的内存 启动成功 其他 参考 解决问题思路:大问题拆小问题.从源头( ...

  6. Kafka启动报错:Timed out waiting for connection while in state: CONNECTING

    1.美图 1.背景 zookeeper 集群启动没有问题,集群状态也正常,但是启动kafka 确报了这个错误: Timed out waiting for connection while in st ...

  7. kafka启动报错:INFO: os::commit_memory(0x00000000c0000000, 1073741824, 0) failed; error=‘Cannot allocate

    现象 启动kafka报错 INFO: os::commit_memory(0x00000000c0000000, 1073741824, 0) failed; error='Cannot alloca ...

  8. kafka启动报错:kafka.common.InconsistentClusterIdException: The Cluster ID KtS-r0FATSudTYqgf-7Ifw doesn‘t

    三 解决办法 cd /tmp/kafka-logs #kafka的Log.dirs路径 修改 meta.properties中的cluster.id值 KtS-r0FATSudTYqgf-7Ifw : ...

  9. kafka启动报错Native memory allocation (mmap) failed to map 1073741824 bytes for

    环境说明 使用了腾讯云的免费试用的1CPU/1GB服务器,通过bin/kafka-server-start.sh config/server.properties命令启动kafka服务,出现以下错误: ...

最新文章

  1. ASP.NET MVC 框架路线图更新 【转】
  2. URLCache探索
  3. .NET 6 使用 string.Create 提升字符串创建和拼接性能
  4. 关于java开发中的实用工具Hutool工具类
  5. IntelliJ IDEA汉化版jar包
  6. 服务器常用陈列raid0,raid1,raid5,raid10(0+1)详解及区别
  7. 虚幻引擎3命令行参数
  8. Python实现:超分子化学的建模------如何操控客体分子穿过主体分子和计算该过程能量变化(高斯(Gauss)输入文件为例,一键批量处理)
  9. 令牌环网 IEEE802.5
  10. Java Swing实现高仿电脑版微信
  11. 2018 06 01 第一次博客 自然语言处理
  12. 权重衰减 weight_decay 是个啥
  13. win7下登录中国银行网银,叫你四步搞定!
  14. 双活数据中心概念及优缺点介绍
  15. 与泽风格--爱的季节
  16. DSP TMS320F280049C 新征程
  17. EXCEL----数据处理(二)----B列中包含了A列的项
  18. 苹果双SIM卡+512GB: 明年苹果将发布超大尺寸iPhoneX Plus
  19. 蓝桥杯真题 数列求值(超范围)(好好审题啊喂)
  20. Linux下开MC服务器

热门文章

  1. 字典树/Trie/前缀树-LeetCode总结:720词典中最长的单词;127. 单词接龙;677. 键值映射;面试题 17.17. 多次搜索;648. 单词替换
  2. 程序员双十一必备购物清单
  3. 6个方面全面了解科学注塑成型理论,你看得懂几个?
  4. 常见的http服务器软件
  5. 变现利器!一文带你学会应用内添加「贴片广告」
  6. 客户成功—以客户为中心,为客户创造价值
  7. 微信商城用什么样的服务器,开通微信商城需要哪些资料?
  8. IC验证培训——实战SV验证学习(lab3)
  9. 石子合并的GarsiaWachs算法
  10. [BZOJ 2844]albus就是要第一个出场