Kafka相关

消息发送 producer 采用 push 模式将消息发到 broker，每条消息都被 append 到 patition 中，顺序写磁盘（保障吞吐率）。 日志文件的删除策略：启动后台线程定期扫描log file列表，把保存时间超过阀值的文件删除，为避免删除文件时仍有read操作(consumer消费)，采取copy-on-write方式。 producer 发送消息到 broker 时，会根据分

>>阅读原文<<