kafka为什么那么快 JAVA面试如何保证消息不被重复消费？如何保证消息消费的幂等性？
JAVA面试如何保证消息不被重复消费？如何保证消息消费的幂等性？
我没事，来这里玩，开始在各种网络上寻找技术信息，之后以“头条”为主。从寻找信息到交朋友。因为我没有想到时代的高度落后。只是在心里想，无法实现现实
如何搭建kafka？该如何学习kafka？
百度很多
卡夫卡删除数据有两种方式
根据时间，删除过期消息一段时间后
根据消息大小，删除超过一定大小的最旧数据
Kafka delete data的最小单位：segment
Kafka delete data主逻辑：Kafka源代码
def cleanuplog（）{debug（”beging log cleanup。。。）var总计=0 val开始时间=时间.毫秒For（log
Kafka在一段时间内（配置文件设置）调用cleanuplogs一次，删除所有需要删除的日志数据。
Cleanupexpiredsegments负责清除超时数据
private def Cleanupexpiredsegments（log:log）：int={val startms=时间.毫秒log.deleteOldSegments文件（开始时间->上次修改时间>log.config.retentions保留)}
cleanupsegmenttomaintainsize负责清理大于大小的数据私有def cleanupsegmentstomaintainsize（log:log）：int={if（log.config.retentionSize文件=0）{差异-=段.尺寸真}否则{假}log.deleteOldSegments文件（应该删除）}
kafka为什么那么快 为什么要使用kafka kafka菜鸟教程
版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。
