kafka持久化原理

Topic在逻辑上能够被认为是一个queue。每条消费都必须指定它的topic,能够简单理解为必须指明把这条消息放进哪一个queue里。为了使得Kafka的吞吐率能够水平扩展,物理上把topic分红一个或多个partition,每一个partition在物理上对应一个文件夹,该文件夹下存储这个partition的全部消息和索引文件。java     每一个日志文件都是“log entries”序列
相关文章
相关标签/搜索