Topic，即消息主題(ti)。創(chuang)建(jian)Kafka實例成功(gong)后，如(ru)(ru)果沒(mei)有開(kai)(kai)啟“Kafka自動創(chuang)建(jian)Topic”，需要手動創(chuang)建(jian)Topic，然(ran)后才(cai)能進行生(sheng)產消息和消費消息。如(ru)(ru)果實例開(kai)(kai)啟了(le)“Kafka自動創(chuang)建(jian)Topic”，則該操作為可選，在進行生(sheng)產時，會自動創(chuang)建(jian)一個Topic，此Topic的默(mo)認參數值如(ru)(ru)下：分(fen)區數為3，副本數為3，老化時間為72小(xiao)時，不開(kai)(kai)啟同(tong)步復(fu)制和同(tong)步落盤。
本文(wen)主要介(jie)紹手(shou)動創建Topic的操(cao)作(zuo)，有以下三種方式，您可以根據實際情(qing)況(kuang)選擇任意一種方式：
- 方式1：在控制臺創建
- 方式2：在Kafka Manager創建
- 方式3：在Kafka客戶端上創建
方式1：在控制臺創建
步驟 1 登錄分布(bu)式(shi)消(xiao)息服務Kafka控制臺，選擇Kafka實例(li)所在的(de)區域。
步驟 2 在(zai)“Kafka專享版(ban)”頁面，單擊Kafka實例的名稱，進入實例詳情頁面。
步驟(zou) 3 在(zai)“Topic管理”頁簽，單擊“創建Topic”，彈出“創建Topic”對話框。
步驟 4 填寫Topic名(ming)稱和配置信息，單擊(ji)“確定”，完成(cheng)創建Topic。
方式2：在Kafka Manager創建
登錄Kafka Manager后(hou)，在頁(ye)面頂部選擇“Topic > Create”，然(ran)后(hou)按(an)照界面參數(shu)填寫即可。
注意
Topic名稱(cheng)開頭包(bao)含特殊字符，例如(ru)下(xia)劃線“_”、#號“#”時(shi)，監控數據(ju)無法(fa)展示。
方式3：在Kafka客戶端上創建
僅在Kafka客戶端版本為2.2以上時，支持通過kafka-topics.sh創(chuang)建Topic，以(yi)及管理Topic的各類參數。
注意
Topic名稱開頭包含特殊字符，例如下劃線“_”、#號“#”時，監控數據無法展示。
- 未開啟SASL的Kafka專享版實例，在“/{命令行工具所在目錄}/kafka_{version}/bin/”目錄下，通過以下命令創建Topic。
./kafka-topics.sh --create --topic {topic_name} --bootstrap-server {broker_ip}:{port} --partitions {partition_num} --replication-factor {replication_num}
- 已開啟SASL的Kafka專享版實例，通過以下步驟創建Topic。
- （可選）如果已經設置了SSL證書配置，請跳過此步驟。否則請執行以下操作。在Kafka客戶端的“/config”目錄中創建“ssl-user-config.properties”文件，參考使用SASL證書連接增加SSL證書配置。
- 在“/{命令行工具所在目錄}/kafka_{version}/bin/”目錄下，通過以下命令創建Topic。
./kafka-topics.sh --create --topic {topic_name} --bootstrap-server {broker_ip}:{port} --partitions {partition_num} --replication-factor {replication_num} --command-config ./config/ssl-user-config.properties
后續步驟
