Topic日志清理 server.properties： log.cleanup.policy=delete (默認) 1. 按時間維度進行Kafka日志清理 log.retention.hours=1 log.retention.minutes=60 log.retention.ms ...

由於項目原因，最近經常碰到Kafka消息隊列擁堵的情況。碰到這種情況為了不影響在線系統的正常使用，需要大家手動的清理Kafka Log。但是清理Kafka Log又不能單純的去刪除中間環節產生的日志，中間關聯的很多東西需要手動同時去清理，否則可能會導致刪除后客戶端無法消費的情況。 在介紹 ...

由於項目原因，最近經常碰到Kafka消息隊列擁堵的情況。碰到這種情況為了不影響在線系統的正常使用，需要大家手動的清理Kafka Log。但是清理Kafka Log又不能單純的去刪除中間環節產生的日志，中間關聯的很多東西需要手動同時去清理，否則可能會導致刪除后客戶端無法消費的情況。 在介紹手動 ...

背景問題： 使用kafka的路上踩過不少坑，其中一個就是在測試環境使用kafka一陣子以后，發現其日志目錄變的很大，占了磁盤很大空間，定位到指定目錄下發現其中一個系統自動創建的 topic，__consumer_offsets-45（kafka一共創建了50個分別從0~49標識）文件夾很大，上網 ...

由於項目原因，最近經常碰到Kafka消息隊列某topic在集群宕機重啟后無法消費的情況。碰到這種情況，有三步去判斷原因所在： step A：如果用kafka串口（即console-consumer）是可以正常消費該topic，則排除kafka集群出現故障 step B：若平台業務能正常消費 ...

0x00 概述 kafka將topic分成不同的partitions，每個partition的日志分成不同的segments，最后以segment為單位將陳舊的日志從文件系統刪除。 假設kafka的在server.properity文件中設置的日志目錄為tmp/kafka-logs，對於名為 ...

1.kafka如何擴展分區 https://www.cnblogs.com/wgy1/p/11611345.html 2.kafka如何完整刪除topic https://blog.csdn.net/belalds/article/details/80575751 3.kafka manager ...

概述 日志段及其相關代碼是 Kafka 服務器源碼中最為重要的組件代碼之一。你可能會非常關心，在 Kafka 中，消息是如何被保存和組織在一起的。畢竟，不管是學習任何消息引擎，弄明白消息建模方式都是首要的問題。因此，你非常有必要學習日志段這個重要的子模塊的源碼實現。今天，我會帶你詳細看下日志段 ...