326、面试碰到的kafka问题

326、面试碰到的kafka问题

之前面试碰到的kafka问题

kafka原理

kafka怎么做的幂等性

怎么提高单个分区吞吐量

有的broker挡掉了，怎么重新分区

kafka怎么做到数据不丢失

kafka怎么保证exact once

分区幂等性用producerId保证，跨分区用事务保证
利用幂等和事务保证exactly one

Kafka自身根本就没有实现exactly once

exactly once：恰好传输一次
默认情况下acks为-1，生产者会有重传
exactly once只是一种语义罢了，最后产生的效果不就是幂等保证了exactly once嘛个人理解

exactly once当然有的……幂等消息加消费后commit就行。

只是消费者依然要保证幂等消费，因为任何方案都无法保证消费完commit前服务不down机。

除非消费和commit构成一个分布式事务。那需要引入2pc的，真心不值得……

---

kafka压根没重新分区的功能……另外其实大部分问题都是固定套路，哪怕不懂kafka也应该能回答个大概。比如幂等吞吐ha，只是细节实现差异大思路就那么几种。当然如果以是不是kafka的实现判断对错那是面试官有问题……

不知道在说什么：不懂也能回答个大概[牛呀]

昨晚上面试 问Kafka源码里面有哪些模块 哪些包 心累