Kafka在線修改topic日志保存時長(不停機，不重啟)
使用場景： 某些時候，當幾個topic生產者突發產生大量消息時，會造成磁盤空間緊張，這時，除了增加磁盤，另一個方法就是修改配置文件，將日志的保存時間修改小一點，但這兩種方案，都必須停機和重啟kafka，顯然，這在生產集群上，是不能這么處理的。這里，可以通過在線修改單個topic的配置，以覆蓋默認 ...
原文：kafka修改對應topic的日志保存周期
.server.properties配置 在創建topic時候設置參數，會覆蓋server.properties的相同屬性的配置 log.retention.bytes xxx topic每個分區的最大文件大小，一個topic的大小限制 分區數 log.retention.bytes。 沒有大小限制log.retention.bytes和log.retention.minutes任意一個達到要求 ...
2021-07-19 17:53 0 321 推薦指數：
相關推薦
Kafka日志及Topic數據清理
由於項目原因，最近經常碰到Kafka消息隊列擁堵的情況。碰到這種情況為了不影響在線系統的正常使用，需要大家手動的清理Kafka Log。但是清理Kafka Log又不能單純的去刪除中間環節產生的日志，中間關聯的很多東西需要手動同時去清理，否則可能會導致刪除后客戶端無法消費的情況。 在介紹 ...
Kafka日志及Topic數據清理
由於項目原因，最近經常碰到Kafka消息隊列擁堵的情況。碰到這種情況為了不影響在線系統的正常使用，需要大家手動的清理Kafka Log。但是清理Kafka Log又不能單純的去刪除中間環節產生的日志，中間關聯的很多東西需要手動同時去清理，否則可能會導致刪除后客戶端無法消費的情況。 在介紹手動 ...
修改kafka topic offset 的方法
在spark JOB中消費kafka隊列數據時，通過zookeeper記錄了kafka的偏移量，有時數據量較大，JOB處理不過來，這事需要kafka修改偏移量offset，如： 開始嘗試調用kafka內置的類kafka.tools.UpdateOffsetsInZK，修改 ...
（一）kafka修改topic分區的位置
（一）kafka修改topic分區的位置 環境：kafka_2.10-0.8.2.1 + JDK1.7.0_80 1. 查看分區topic的分區分布 $ le-kafka-topics.sh --describe --topic http_zhixin_line1 結果如下： 2. ...
kafka修改topic副本數
工作案例: 大數據開發用系統腳本自動在kafka建topic,檢查后才發現副本數只有1個,存在數據丟失的風險。需要立刻把副本數改為3個。 開始干活，首先想到的是下面的命令： ${BIN_PATH}/kafka-topics.sh --zookeeper ...
Kafka 不停機修改某一個topic數據保存時間
https://blog.csdn.net/zhangshenghang/article/details/89152644 ...
std::set的迭代器不能修改對應的元素
c++不長搞，每次搞都頻繁掉進陷阱里。。。 std::set<int> iset;std::set<int>::iterator it = iset.insert(4).first;(*it)++; // error. 原因：std::set的迭代器不能修改對應的元素 ...