栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

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源码里面有哪些模块 哪些包 心累

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/720967.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号