Kafka宕机引发的高可用问题

问题要从一次Kafka的宕机开始说起。

笔者所在的是一家金融科技公司，但公司内部并没有采用在金融支付领域更为流行的RabbitMQ，而是采用了设计之初就为日志处理而生的Kafka，所以我一直很好奇Kafka的高可用实现和保障。从Kafka部署后，系统内部使用的Kafka一直运行稳定，没有出现不可用的情况。

但最近系统测试人员常反馈偶有Kafka消费者收不到消息的情况，登陆管理界面发现三个节点中有一个节点宕机挂掉了。但是按照高可用的理念，三个节点还有两个节点可用怎么就引起了整个集群的消费者都接收不到消息呢？

要解决这个问题，就要从Kafka的高可用实现开始讲起。

正文

最近整理了一份 Netty 相关的文档干货，讲解很系统。今天分享给大家。看完这份文档你将获得哪些收获？

文档围绕“基于 Netty 手写 RPC 框架”的主题，从小试牛刀到高级应用，其中涉及到很多 Netty 编程中的设计难点，比如：

• TCP 的拆包与粘包

• Netty的概念及体系结构

• 读写空闲检测、心跳机制、WebSocket 长连接

• Netty源码剖析

• RPC底层通信原理

• 手写聊天室、 Tomcat

本文档共分为四大部分，具体内容如下：

第一部分Netty的概念及体系结构

1. 第1章　Netty——异步和事件驱动
2. 第2章　你的第一款Netty应用程序
3. 第3章　Netty的组件和设计
4. 第4章　传输
5. 第5章　ByteBuf
6. 第6章　ChannelHandler和 ChannelPipeline
7. 第7章　EventLoop和线程模型
8. 第8章　引导
9. 第9章　单元测试

第二部分编解码器

1. 第10章　编解码器框架
2. 第11章　预置的ChannelHandler和编解码器

第三部分网络协议

1. 第12章　WebSocket
2. 第13章　使用UDP广播事件

第四部分案例研究

1. 第14章　案例研究，第一部分
2. 第15章　案例研究，第二部分

最后

针对最近很多人都在面试，我这边也整理了相当多的面试专题资料，也有其他大厂的面经。希望可以帮助到大家。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

[外链图片转存中…(img-liWJwUVo-1650602622829)]

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。