-
存储方式
- 物理上把 topic 分成一个或多个 patition,每个 patition 物理上对应一个文件夹(该文件夹存储该 patition 的所有消息和索引文件)
-
存储策略
-
无论消息是否被消费,kafka 都会保留所有消息。有两种策略可以删除旧数据:
-
基于时间:log.retention.hours=xxx
-
基于大小:log.retention.bytes=xxx
-
-
存储方式
存储策略
无论消息是否被消费,kafka 都会保留所有消息。有两种策略可以删除旧数据:
基于时间:log.retention.hours=xxx
基于大小:log.retention.bytes=xxx