操作場景
Kafka實(shi)例采用物理(li)隔離(li)的方式部署,租戶獨占Kafka實(shi)例。支(zhi)持用戶自定義(yi)規格和自定義(yi)特性,您可(ke)以(yi)根據業務需要定制相應計算能(neng)力和存儲空間的Kafka實(shi)例。
購買前須知
- Kafka實例運行于虛擬私有云,購買實例前,需保證有可用的虛擬私有云,并且已配置好安全組與子網。
- (可選)如果需要通過公網訪問Kafka實例,請提前準備彈性IP地址。
操作步驟
步驟 1 登錄(lu)管理控(kong)制臺。
步驟 2 在管理控制臺右上角單擊
,選擇區域。
說明此處(chu)請(qing)選擇(ze)與您的應(ying)用(yong)服務相同的區(qu)域。
步驟 3 在管理控制臺左上角單擊
,選擇“企業中間件”-“分布式(shi)消(xiao)息(xi)服務(wu)”-“Kafka專享(xiang)(xiang)版”,進入分布式(shi)消(xiao)息(xi)服務(wu)Kafka專享(xiang)(xiang)版頁面(mian)。
步驟 4 單擊頁面右(you)上(shang)方(fang)的“購買Kafka實例(li)”。
每個(ge)項目默認最多可(ke)以(yi)創(chuang)建(jian)(jian)100個(ge)Kafka實(shi)例,如(ru)果您想(xiang)創(chuang)建(jian)(jian)更多實(shi)例,請(qing)聯(lian)系客服申請(qing)增加配額。
步驟(zou) 5 選擇(ze)“計費模式”、“區(qu)域”、“項目(mu)”和“可(ke)用區(qu)”。
步驟 6 設置“實例名稱”和“企(qi)業(ye)項(xiang)目”。
步(bu)驟 7 設置實例信息。
- 版本:Kafka的版本號,支持1.1.0、2.3.0和2.7,根據實際情況選擇,推薦使用2.7。 Kafka實例創建后,版本號不支持修改 。
- CPU架構:支持“x86計算”,保持默認值即可。
- 在“代理規格”中,請根據業務需求選擇相應的代理規格。在“代理數量”中,選擇代理個數。
單個代理(li)最大分區(qu)數(shu)*代理(li)個數(shu)=實(shi)例分區(qu)數(shu)上(shang)限。當所有Topic的總分區(qu)數(shu)大于(yu)實(shi)例分區(qu)數(shu)上(shang)限時(shi),創建Topic失敗。
- 在“存儲空間”區域,您根據實際需要選擇存儲Kafka數據的磁盤類型和總磁盤大小。 Kafka實例創建后,磁盤類型不支持修改 。
存(cun)(cun)儲(chu)空(kong)間包含所有副本(ben)(ben)存(cun)(cun)儲(chu)空(kong)間總和,建議根據(ju)業務(wu)消息體(ti)積以及(ji)副本(ben)(ben)數(shu)量(liang)選擇(ze)存(cun)(cun)儲(chu)空(kong)間大小(xiao)。假設業務(wu)存(cun)(cun)儲(chu)數(shu)據(ju)保留天數(shu)內磁(ci)盤(pan)(pan)大小(xiao)為100GB,則磁(ci)盤(pan)(pan)容量(liang)最少(shao)為100GB*副本(ben)(ben)數(shu) + 預留磁(ci)盤(pan)(pan)大小(xiao)100GB。
創建(jian)實(shi)例時會(hui)進行(xing)磁(ci)(ci)盤格式化(hua)(hua),磁(ci)(ci)盤格式化(hua)(hua)會(hui)導致實(shi)際可用磁(ci)(ci)盤為(wei)總磁(ci)(ci)盤的93%~95%。
- 在“容量閾值策略”區域,設置磁盤使用達到容量閾值后的消息處理策略,容量閾值為95%。
- 自動刪除:可以正常生產和消費消息,但是會刪除最早的10%的消息,以保證磁盤容量充足。該場景優先保障業務不中斷,數據存在丟失的風險。
- 生產受限:無法繼續生產消息,但可以繼續消費消息。該場景適用于對數據不能丟的業務場景,但是會導致生產業務失敗。
圖 創建Kafka實例


步驟 8 設置實例網絡環境信息。
- 在“虛擬私有云”下拉列表,選擇已經創建好的虛擬私有云和子網。
虛(xu)擬私有云可以(yi)為您的(de)(de)Kafka實例構建(jian)隔離的(de)(de)、能自主配置(zhi)和管理的(de)(de)虛(xu)擬網絡(luo)環境。
說明虛擬私有(you)云(yun)和子網在(zai)Kafka實例(li)創(chuang)建完成后(hou),不支(zhi)持修(xiu)改。
子(zi)網開啟(qi)IPv6后,Kafka實例支持IPv6功能(neng)。
- IPv6:子網開啟IPv6后,支持設置此參數。開啟IPv6后,客戶端可以使用IPv6地址連接實例。
說明
開啟(qi)IPv6的實(shi)例不支持動(dong)態開啟(qi)和關閉SASL_SSL功能。
實例創建成功后(hou),不支持(chi)修改IPv6開關(guan)。
- 在“安全組”下拉列表,可以選擇已經創建好的安全組。
安全組是一組對Kafka實例的(de)(de)訪(fang)問規則的(de)(de)集合。您可以單擊右側的(de)(de)“管理安全組”,跳(tiao)轉到(dao)網絡控制(zhi)臺的(de)(de)“安全組”頁面,查看或創(chuang)建安全組。
步驟 9 設置登錄Kafka Manager的用戶名和密碼。創建實例后,Kafka Manager用戶名無法修改。
Kafka Manager是開源的(de)Kafka集群管理工具(ju),實(shi)例創建成功后,實(shi)例詳情頁(ye)面(mian)會(hui)展示Kafka Manager登錄(lu)地址,您可(ke)登錄(lu)Kafka Manager頁(ye)面(mian),查(cha)看Kafka集群的(de)監控、代(dai)理等(deng)信息。
步驟 10 設置實例購買時長。
當選擇(ze)了“包(bao)年/包(bao)月”付費模式(shi)時,頁面才顯示“購買(mai)時長”參數,您需(xu)要根(gen)據業務需(xu)要選擇(ze)。
步驟 11 單擊(ji)“更多(duo)配置”,設(she)置更多(duo)相關信(xin)息。
- 設置“公網訪問”。
“公(gong)網(wang)訪(fang)問”默認為關閉狀態,您可以選(xuan)擇是(shi)否開(kai)啟。
開啟公網(wang)訪(fang)問后,還需要為每個(ge)代理設置對應的IPv4彈性(xing)IP地址。
說明如果開啟了(le)IPv6功(gong)能,支持設置(zhi)此(ci)參數。
- 設置“Kafka SASL_SSL”。
客戶(hu)端連接Kafka實(shi)例時,是否開啟(qi)SSL認證。開啟(qi)Kafka SASL_SSL,則數(shu)據(ju)加密(mi)傳輸,安全性更高。
“Kafka SASL_SSL”默認為關閉狀態,您可以選擇是否開啟。 Kafka實例創建后,Kafka SASL_SSL開關不支持修改 ,請慎重(zhong)選擇。如果創(chuang)建后需(xu)要(yao)修改,需(xu)要(yao)重(zhong)新創(chuang)建實例。
開啟(qi)(qi)Kafka SASL_SSL后(hou),您可以選(xuan)擇是(shi)否開啟(qi)(qi)“SASL PLAIN 機(ji)(ji)制(zhi)(zhi)”。未開啟(qi)(qi)“SASL PLAIN 機(ji)(ji)制(zhi)(zhi)”時,使用(yong)SCRAM-SHA-512機(ji)(ji)制(zhi)(zhi)傳輸數據,開啟(qi)(qi)“SASL PLAIN 機(ji)(ji)制(zhi)(zhi)”后(hou),同時支持(chi)SCRAM-SHA-512機(ji)(ji)制(zhi)(zhi)和PLAIN機(ji)(ji)制(zhi)(zhi),根(gen)據實際情況選(xuan)擇其中任意一種(zhong)配置(zhi)連接。Kafka實例(li)創建后(hou),SASL PLAIN機(ji)(ji)制(zhi)(zhi)開關不支持(chi)修改。
什么是SCRAM-SHA-512機制和PLAIN機制?
- SCRAM-SHA-512機制:采用哈希算法對用戶名與密碼生成憑證,進行身份校驗的安全認證機制,比PLAIN機制安全性更高。
- PLAIN機制:一種簡單的用戶名密碼校驗機制。
開啟Kafka SASL_SSL后,您(nin)需要(yao)設(she)置連接Kafka實例(li)的用戶名和(he)密碼。
- 設置“Kafka自動創建Topic”。
“Kafka自動創建Topic”默認為關閉狀態,您可以選擇是否開啟。
開啟“Kafka自動創(chuang)建Topic”表(biao)示生產或消費一個(ge)未創(chuang)建的(de)Topic時(shi),系統(tong)會自動創(chuang)建此Topic,此Topic的(de)默(mo)認參數值(zhi)如(ru)下:分區數為(wei)(wei)3,副本數為(wei)(wei)3,老(lao)化(hua)時(shi)間為(wei)(wei)72小(xiao)時(shi),不(bu)開啟同(tong)步復制和同(tong)步落盤。
如果在“配置參數(shu)(shu)”中修(xiu)改(gai)“log.retention.hours”、“default.replication.factor”或“num.partitions”的(de)參數(shu)(shu)值(zhi)(zhi),此(ci)后自動(dong)創建的(de)Topic參數(shu)(shu)值(zhi)(zhi)為(wei)(wei)修(xiu)改(gai)后的(de)參數(shu)(shu)值(zhi)(zhi)。例如:“num.partitions”修(xiu)改(gai)為(wei)(wei)“5”,自動(dong)創建的(de)Topic參數(shu)(shu)值(zhi)(zhi)如下:分區(qu)數(shu)(shu)為(wei)(wei)5,副本數(shu)(shu)為(wei)(wei)3,老化時間(jian)為(wei)(wei)72小時,不開啟同步復制和同步落盤。
- 設置“標簽”。
標簽用(yong)于(yu)標識云資源(yuan),當(dang)您(nin)擁有(you)相同類型(xing)的許多云資源(yuan)時,可以(yi)使用(yong)標簽按各種(zhong)維度(例如(ru)用(yong)途、所有(you)者(zhe)或環境)對云資源(yuan)進行分類。
- 如果您已經預定義了標簽,在“標簽鍵”和“標簽值”中選擇已經定義的標簽鍵值對。另外,您可以單擊“查看預定義標簽”,跳轉到標簽管理服務頁面,查看已經預定義的標簽,或者創建新的標簽。
- 您也可以直接在“標簽鍵”和“標簽值”中設置標簽。
當前每個Kafka實例最多支持設置20個不同標簽,標簽的命名規格,請參考管理實例標簽章節。
- 設置實例的描述信息。
步驟 12 填寫(xie)完(wan)上述信息后,單擊“立即購買”,進入(ru)規格(ge)確認頁面。
步驟 13 確認實例信息無誤后,單擊(ji)“提交(jiao)”。
步驟 14 在實(shi)例列表頁面,查看(kan)Kafka實(shi)例是否創建(jian)成功。
創建實例大約需要(yao)3到15分鐘,此時(shi)實例的“狀態”為“創建中”。
- 當實例的“狀態”變為“運行中”時,說明實例創建成功。
- 如果創建實例失敗,在信息欄的“創建失敗任務”中查看創建失敗的實例。請參考刪除實例,刪除創建失敗的實例,然后重新創建。如果重新創建仍然失敗,請聯系客服。
說明創(chuang)建失(shi)敗的實例,不會占用其他資源。