hahawo110 2018-09-12 03:06 采纳率: 0%
浏览 5031

kafka在一台机器上模拟集群,为什么关闭一个broker,整体集群就不能消费了,求大神解答

kafka在一台机器上模拟集群,为什么关闭一个broker,整体集群就不能消费了。消费就一直卡主等待的状况。

环境:
1.一台机器运行了一个zookeeper,启动文件是在kafka/bin/zookeeper-server-start.sh
2.分别把kafka文件件复制了四份,改变里面server.properties中borker.id分别为1,2,3,4
3.启动机器,正常可以消费topic是cxl的
4.关闭borker.id是1的kafka服务,就没有办法消费cxl
topic的信息
图片说明

现在就不太明白正常集群挂掉一个,整体集群应该是不受影响的,从topic信息上看我的分片也在borker 2上,而我关掉的是broker1应该没有什么影响,但是现在为什么不能消费了?

  • 写回答

2条回答 默认 最新

  • 麦兜仔 2019-05-21 13:59
    关注

    虽然topic的副本数是2,但是 partition的数量为1,所以导致这个topic只会在一个broker(leader partition)中存储数据。
    出现上诉情况的原因,可以是在leader partition中存储数据的时候,其他follower partition还未来得及从leader partition中拉取数据,
    leader partition所在的broker就挂掉了。从而导致follower partition没有同步到所有数据,此时因为leader partition所在的broker挂掉了,
    在ISR中的follower partition会被选举为leader partition,此时的leader partition的数据是缺失的。

    评论

报告相同问题?

悬赏问题

  • ¥15 LiBeAs的带隙等于0.997eV,计算阴离子的N和P
  • ¥15 关于#windows#的问题:怎么用WIN 11系统的电脑 克隆WIN NT3.51-4.0系统的硬盘
  • ¥15 matlab有关常微分方程的问题求解决
  • ¥15 perl MISA分析p3_in脚本出错
  • ¥15 k8s部署jupyterlab,jupyterlab保存不了文件
  • ¥15 ubuntu虚拟机打包apk错误
  • ¥199 rust编程架构设计的方案 有偿
  • ¥15 回答4f系统的像差计算
  • ¥15 java如何提取出pdf里的文字?
  • ¥100 求三轴之间相互配合画圆以及直线的算法