本文將為您(nin)介(jie)紹分布式(shi)消息服務Kafka入門的基本流程(cheng),主要包括控制臺創建(jian)Kafka專享(xiang)版實(shi)例、使用彈性云(yun)主機連接實(shi)例的操(cao)作,幫(bang)助您(nin)快速上手Kafka。
您還可以(yi)通過API方式創建Kafka實例、在(zai)業(ye)務(wu)代碼中連接Kafka實例。
操作流程
圖Kafka使用流(liu)程


Kafka實例運行(xing)于虛擬私有(you)(you)云(yun)中,在(zai)創(chuang)建(jian)實例前需要確保有(you)(you)可用(yong)的虛擬私有(you)(you)云(yun)。
Kafka實例創建后,您(nin)需要(yao)在彈(dan)性云主機中(zhong)下載和安(an)裝Kafka開源(yuan)客戶端(duan),然(ran)后才能進行(xing)生(sheng)產消息和消費消息。
在創(chuang)(chuang)建(jian)實(shi)例時(shi),您可以選擇是否開啟SASL訪問,開啟后,數據加(jia)密傳輸,安(an)全(quan)性更高。同時(shi),SASL開關只能在創(chuang)(chuang)建(jian)實(shi)例時(shi)設置,實(shi)例創(chuang)(chuang)建(jian)成功后,不(bu)支持修改。
- (可選)創建Topic
Kafka實例創建(jian)成功后,如果沒有開(kai)啟(qi)“Kafka自(zi)動(dong)創建(jian)Topic”,需要手動(dong)創建(jian)Topic,然后才(cai)能(neng)進行生產消息(xi)和消費消息(xi)。
- 連接實例
針對(dui)實(shi)例是否(fou)開(kai)啟SASL開(kai)關,在(zai)連接時是否(fou)需要下載證(zheng)書(shu),區分以下兩種場(chang)景(jing):
配置Kafka實例監控(kong)告警(jing)策(ce)略,監控(kong)實際業務運(yun)行狀態。
說明關于Kafka的相關概念,請參考Kafka基本概念。