无论消息是否被消费 , Kafka都会保留所有消息 。有两种策略可以删除旧数据:
基于时间:log.retention.hours=168基于大小:log.retention.bytes=1073741824
Consumer消费消息Kafka集群保持所有的消息 , 直到它们过期(无论消息是否被消费) 。实际上消费者所持有的仅有的元数据就是这个offset(偏移量) , 也就是说offset由消费者来控制:正常情况当消费者消费消息的时候 , 偏移量也线性的的增加 。但是实际偏移量由消费者控制 , 消费者可以将偏移量重置为更早的位置 , 重新读取消息 。可以看到这种设计对消费者来说操作自如 , 一个消费者的操作不会影响其它消费者对此log的处理 。
以上关于本文的内容,仅作参考!温馨提示:如遇健康、疾病相关的问题,请您及时就医或请专业人士给予相关指导!
「四川龙网」www.sichuanlong.com小编还为您精选了以下内容,希望对您有所帮助:- 交互过程及区别介绍 socket服务端和客户端的区别
- 送33朵玫瑰代表什么(生生世世的爱 33朵玫瑰代表什么意思)
- 做空:最危险的交易 做空是什么意思啊
- 设置ip地址的详细教程 win10如何手动设置ip地址
- 简介后备式ups工作原理和优势 后备式ups的性能特点有哪些
- 分析这4个本质区别 笔记本睡眠和休眠的区别
- 网络协议基础知识应用 常见的网络协议有哪三种
- 纯干货——史上最全的快捷键 刷新快捷键
- 八种适合糖友吃的低糖水果 低糖水果
- 我国最长的十大河流是哪些? 中国最长的河流