美文网首页
broker 保存消息

broker 保存消息

作者: 一个人一匹马 | 来源:发表于2019-03-03 12:28 被阅读0次
存储方式

物理上把topic分成一个或多个patition(对应 server.properties 中的num.partitions=3配置),每个patition物理上对应一个文件夹(该文件夹存储该patition的所有消息和索引文件)

3.2.2 存储策略
无论消息是否被消费,kafka都会保留所有消息。有两种策略可以删除旧数据:
1)基于时间:log.retention.hours=168
2)基于大小:log.retention.bytes=1073741824
需要注意的是,因为Kafka读取特定消息的时间复杂度为O(1),即与文件大小无关,所以这里删除过期文件与提高 Kafka 性能无关。

相关文章

网友评论

      本文标题:broker 保存消息

      本文链接:https://www.haomeiwen.com/subject/upypuqtx.html