Kafka宕机引发的高可用问题
问题要从一次Kafka的宕机开始说起。
笔者所在的是一家金融科技公司，但公司内部并没有采用在金融支付领域更为流行的RabbitMQ，而是采用了设计之初就为日志处理而生的Kafka，所以我一直很好奇Kafka的高可用实现和保障。从Kafka部署后，系统内部使用的Kafka一直运行稳定，没有出现不可用的情况。
但最近系统测试人员常反馈偶有Kafka消费者收不到消息的情况，登陆管理界面发现三个节点中有一个节点宕机挂掉了。但是按照高可用的理念，三个节点还有两个节点可用怎么就引起了整个集群的消费者都接收不到消息呢？
要解决这个问题，就要从Kafka的高可用实现开始讲起。
阿里
- mq 消息可靠性,幂等如何保证
- 分布式锁的实现方案比较,为什么选择 zookeeper, zookeeper 一致性协议原理
- 线程池参数,阻塞队列实现
- 一致性 Hash解决什么问题, 如何实现? 虚拟节点的作用?
- Java 锁的实现方式, 比较? AQS实现原理?公平非公平实现原理?
- CAS 实现原理
- volatile 实现原理, 单例模式
- java 内存模型, gc 调优的经历. cms gc 的几个阶段, 为什么会出现 stop the world. 常见可优化参数有哪些.
- 为什么需要优化 gc, gc 会导致什么问题.
- mysql 事务隔离级别. mvcc 实现原理
- mysql 索引原理. 为什么使用 B+树. 及何时无法使用索引?
- mysql 架构, 引擎层和 server层 各自负责什么.
- hashmap 及 concurrenthashmap 实现原理
- Spring aop原理，如何定义新的spring xml 标签
- 合并两个有序链表
- 如何设计一个大型活动的安保系统(开放题)
美团
数据库和缓存的一致性问题。先更新数据库，再更新缓存，若更新完数据库了，还没有更新缓存，此时有请求过来了，访问到了缓存中的数据，怎么办？
聚簇索引/非聚簇索引，mysql索引底层实现，为什么不用B-tree，为什么不用hash，叶子结点存放的是数据还是指向数据的内存地址，使用索引需要注意的几个地方
mysql默认的事务隔离级别，mvcc，rr怎么实现的，rc如何实现的
mysql间隙锁有没有了解，死锁有没有了解，写一段会造成死锁的sql语句，死锁发生了如何解决，mysql有没有提供什么机制去解决死锁
谈下对GC的了解，何为垃圾，有哪些GC算法，有哪些垃圾回收器，cms和g1的区别，emm，还有一个直击灵魂的问题，看过cms的源码吗
有没有排查过线上oom的问题，如何排查的
有没有使用过jvm自带的工具，如何使用的
假设有下图所示的一个full gc 的图，纵向是内存使用情况，横向是时间，你如何排查这个full gc的问题，怎么去解决你说出来的这些问题
说说对java中集合类的理解，项目中用过哪些，哪个地方用的，如何使用的
对CAS的理解，CAS带来的问题，如何解决这些问题
volatile底层、synchronized底层、锁升级的过程、MESI
ehcache支持哪些缓存
juc有研究没有，讲一讲
聊项目，画项目架构图，画一个用户从发起请求 到接收到响应 中间经过哪些服务 每个服务做什么事情 的流程图
讲项目中的难点、挑战，如何解决的，项目这一块会问的特别细
如何保证RocketMQ 消息的顺序性，如何解决重复消费问题
项目中如何保证接口的幂等操作
讲一讲对redis 的了解，项目中如何使用的，哪个地方使用的，为什么要使用
哨兵机制、redis两种备份方式的区别，项目中用的哪种，为什么
讲一讲对分布式锁的了解
项目中系统监控怎么做的
如何理解Spring中的AOP 和 IOC，以及DI，读过Spring源码没有
读过MyBatis源码没有
说一个你了解最多的框架，说出你的理解
如何理解分布式事务，为什么会出现这个问题，如何去解决，了解哪些分布式事务中间件
聊一聊对分库分表的理解
hystrix功能 & 在项目中怎么使用的 & hystrix 怎么检测断路器是否要开启/关闭 & hystrix 实现原理，除hystrix之外的其他熔断限流中间件有了解没有，了解多少说多少
dubbo有了解没有
怎么理解java 中和 mysql 中的乐观锁、悲观锁
一致性hash
最后
这份《“java高分面试指南”-25分类227页1000+题50w+字解析》同样可分享给有需要的朋友，感兴趣的伙伴们可挑战一下自我，在不看答案解析的情况，测试测试自己的解题水平，这样也能达到事半功倍的效果！（好东西要大家一起看才香，下载请点击这里）
.(img-2kY9mEgV-1621494975343)]
[外链图片转存中…(img-XQmPVPIY-1621494975345)]
