kafka 小白,一直不理解,為什么需要打開這個開關才允許topic洗掉,看到過原始碼,
def start() {
if (isDeleteTopicEnabled) {
//如果topic.delete.enable=true,則啟動洗掉執行緒
deleteTopicsThread = new DeleteTopicsThread()
if (topicsToBeDeleted.size > 0)
deleteTopicStateChanged.set(true)
deleteTopicsThread.start()
}
}
但是不理解啊,是為了不讓topic被隨意洗掉嗎,所以設計了這么一個按鈕
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/50620.html
上一篇:spark往hbase寫資料
