前提條件
在創建Kafka實例前,需要保證存在可使用的虛擬私有云。創建方法,請參考《虛擬私有云 用戶指南》的“創建虛擬私有云和子網”。
如果(guo)您已有虛擬(ni)私有云,可(ke)重復使(shi)用,不需(xu)要多次(ci)創建(jian)。
操作步驟
步驟 1 登錄分布式(shi)消息(xi)服務Kafka控制臺,單擊頁面右上(shang)方的“購買Kafka實例”。
步驟 2 選擇計費模式。
步驟 3 在“區域”下拉列(lie)表(biao)中,選擇靠近您應(ying)用程序的(de)區域,可降低網絡(luo)延時、提高訪(fang)問速度。
步驟(zou) 4 在“項(xiang)目”下拉(la)列表中(zhong),選擇項(xiang)目。
步驟(zou) 5 在(zai)“可用區”區域,根據實(shi)際情(qing)況選(xuan)擇1個或者3個及以上(shang)可用區。
步(bu)驟 6 設置“實例(li)名稱”和(he)“企業項(xiang)目”。
步驟 7 設置實例信息。
- 版本:Kafka的版本號,支持1.1.0、2.3.0和2.7,根據實際情況選擇,推薦使用2.7。 Kafka實例創建后,版本號不支持修改 。
- CPU架構:支持“x86計算”,保持默認值即可。
- 在“代理規格”中,請根據業務需求選擇相應的代理規格。在“代理數量”中,選擇代理個數。
單個代理(li)最大分區數*代理(li)個數=實(shi)例分區數上限。當(dang)所有Topic的總分區數大于實(shi)例分區數上限時,創(chuang)建(jian)Topic失敗。
- 在“存儲空間”區域,您根據實際需要選擇存儲Kafka數據的磁盤類型和總磁盤大小。 Kafka實例創建后,磁盤類型不支持修改 。
存(cun)(cun)(cun)儲(chu)空(kong)間(jian)包含所有(you)副(fu)本(ben)存(cun)(cun)(cun)儲(chu)空(kong)間(jian)總(zong)和,建議(yi)根據業務消息體積以及副(fu)本(ben)數量選擇存(cun)(cun)(cun)儲(chu)空(kong)間(jian)大小(xiao)(xiao)。假設業務存(cun)(cun)(cun)儲(chu)數據保(bao)留天數內磁(ci)(ci)盤大小(xiao)(xiao)為100GB,則磁(ci)(ci)盤容量最少為100GB*副(fu)本(ben)數 + 預留磁(ci)(ci)盤大小(xiao)(xiao)100GB。
創建實例時會進行磁(ci)盤(pan)格式化,磁(ci)盤(pan)格式化會導致實際可用磁(ci)盤(pan)為(wei)總磁(ci)盤(pan)的93%~95%。
- 在“容量閾值策略”區域,設置磁盤使用達到容量閾值后的消息處理策略,容量閾值為95%。
- 自動刪除:可以正常生產和消費消息,但是會刪除最早的10%的消息,以保證磁盤容量充足。該場景優先保障業務不中斷,數據存在丟失的風險。
- 生產受限:無法繼續生產消息,但可以繼續消費消息。該場景適用于對數據不能丟的業務場景,但是會導致生產業務失敗。
圖 創(chuang)建Kafka實(shi)例


步驟 8 設置(zhi)實例網絡環(huan)境信息。
- 在“虛擬私有云”下拉列表,選擇已經創建好的虛擬私有云和子網。
說明虛擬私有云和子網在Kafka實例創建完成后,不支持修改。
- 在“安全組”下拉列表,可以選擇已經創建好的安全組。
安全(quan)組(zu)是一組(zu)對Kafka實例的訪(fang)問(wen)規則(ze)的集合。您可以單擊右側的“管理安全(quan)組(zu)”,跳(tiao)轉(zhuan)到網(wang)絡控制(zhi)臺的“安全(quan)組(zu)”頁面,查看或創建安全(quan)組(zu)。
步驟 9 設置登錄Kafka Manager的用戶名和密碼。創建實例后,Kafka Manager用戶名無法修改。
Kafka Manager是(shi)開源的Kafka集(ji)群管理工具,實(shi)例(li)創建成(cheng)功后,實(shi)例(li)詳情頁面(mian)會展示Kafka Manager登錄地址,您可登錄Kafka Manager頁面(mian),查看Kafka集(ji)群的監控、代理等信息。
步驟 10 設置實例(li)購(gou)買時長(chang)。
當選擇了“包年/包月”付費模式時,頁面才顯示“購買時長”參數,您需(xu)要根據(ju)業務需(xu)要選擇。
步驟 11 單擊(ji)“更多配置(zhi)”,設置(zhi)更多相關信息。
- 設置“公網訪問”。
“公網訪(fang)問”默認(ren)為關閉狀態,根(gen)據業(ye)務(wu)需(xu)求選擇是否開(kai)啟。開(kai)啟公網訪(fang)問后,還需(xu)要(yao)為每個代理設置對(dui)應的IPv4彈性IP地址。
圖 設置公網訪問開關(guan)


- 設置“Kafka SASL_SSL”。
客戶(hu)端(duan)連接Kafka實例時,是否開啟(qi)SSL認證。開啟(qi)Kafka SASL_SSL,則(ze)數據加(jia)密傳輸(shu),安全性更(geng)高。
“Kafka SASL_SSL”默認為關閉狀態,您可以選擇是否開啟。 Kafka實例創建后,Kafka SASL_SSL開關不支持修改 ,請慎(shen)重選擇(ze)。如果創建后需(xu)要修改,需(xu)要重新(xin)創建實例。
開(kai)啟Kafka SASL_SSL后,您可(ke)以(yi)選擇是否開(kai)啟“SASL PLAIN 機制(zhi)(zhi)”。未開(kai)啟“SASL PLAIN 機制(zhi)(zhi)”時,使用SCRAM-SHA-512機制(zhi)(zhi)傳輸數據,開(kai)啟“SASL PLAIN 機制(zhi)(zhi)”后,同時支(zhi)(zhi)持(chi)SCRAM-SHA-512機制(zhi)(zhi)和PLAIN機制(zhi)(zhi),根(gen)據實際情況選擇其中任意(yi)一種配置(zhi)連接。Kafka實例創建后,SASL PLAIN機制(zhi)(zhi)開(kai)關不支(zhi)(zhi)持(chi)修改。
什么是SCRAM-SHA-512機制和PLAIN機制?
- SCRAM-SHA-512機制:采用哈希算法對用戶名與密碼生成憑證,進行身份校驗的安全認證機制,比PLAIN機制安全性更高。
- PLAIN機制:一種簡單的用戶名密碼校驗機制。
開(kai)啟Kafka SASL_SSL后,您(nin)需要設(she)置連接Kafka實例的用戶(hu)名(ming)和密(mi)碼。
- 設置“Kafka自動創建Topic”。
“Kafka自動(dong)創建Topic”默(mo)認為關閉狀(zhuang)態(tai),您可以選(xuan)擇是否開啟。
開啟“Kafka自(zi)動創(chuang)建(jian)Topic”表(biao)示生(sheng)產(chan)或消費一個未創(chuang)建(jian)的Topic時(shi),系統(tong)會自(zi)動創(chuang)建(jian)此Topic,此Topic的默認參數(shu)(shu)值(zhi)如下(xia):分區(qu)數(shu)(shu)為3,副本(ben)數(shu)(shu)為3,老化時(shi)間為72小時(shi),不開啟同(tong)步(bu)復制(zhi)和同(tong)步(bu)落(luo)盤(pan)。
如果在“配(pei)置參數(shu)”中(zhong)修(xiu)改“log.retention.hours”、“default.replication.factor”或“num.partitions”的參數(shu)值(zhi),此后自(zi)動創建的Topic參數(shu)值(zhi)為(wei)(wei)修(xiu)改后的參數(shu)值(zhi)。例(li)如:“num.partitions”修(xiu)改為(wei)(wei)“5”,自(zi)動創建的Topic參數(shu)值(zhi)如下:分區數(shu)為(wei)(wei)5,副本數(shu)為(wei)(wei)3,老化時間為(wei)(wei)72小時,不開啟同步(bu)復制和同步(bu)落盤(pan)。
- 設置“標簽”。
標簽(qian)用(yong)于標識云(yun)資源,當(dang)您擁有相同類(lei)型的許多云(yun)資源時,可以使用(yong)標簽(qian)按各種維度(du)(例如用(yong)途、所(suo)有者或環境)對云(yun)資源進行(xing)分類(lei)。
- 如果您已經預定義了標簽,在“標簽鍵”和“標簽值”中選擇已經定義的標簽鍵值對。另外,您可以單擊“查看預定義標簽”,跳轉到標簽管理服務頁面,查看已經預定義的標簽,或者創建新的標簽。
- 您也可以直接在“標簽鍵”和“標簽值”中設置標簽。
當前每個Kafka實例最多支持設置20個不同標簽,標簽的命名規格,請參考管理實例標簽。
- 設置實例的描述信息。
步(bu)驟 12 填寫完上述信(xin)息后(hou),單(dan)擊“立即購買”,進入規格確認(ren)頁(ye)面。
步驟 13 確認實(shi)例(li)信息無誤后(hou),提交請求(qiu)。
步(bu)驟 14 單擊“返回Kafka專享版”,查(cha)看Kafka實(shi)例(li)是否創建成功。
創(chuang)建(jian)實例大約需要3到(dao)15分鐘,此時實例的“狀(zhuang)態(tai)”為“創(chuang)建(jian)中(zhong)”。
- 當實例的“狀態”變為“運行中”時,說明實例創建成功。
- 如果創建實例失敗,在信息欄的“創建失敗任務”中查看創建失敗的實例。請刪除創建失敗的實例,然后重新創建。如果重新創建仍然失敗,請聯系客服。
說明創建失敗的實例,不會占用其他資源。