當使用云消息隊列 Kafka 版進行消息收發時，您需要在已成功部署的Kafka實例中創建Topic和Group資源。生產者需要將消息發送至指定Topic，消費者通過訂閱Topic獲取消息進行消費。消費者消費消息時，需要指定Group訂閱對應的Topic。Group和Topic的關系是N∶N，即同一個Group可以訂閱多個Topic，同一個Topic也可以被多個Group訂閱。
前提條件
您已根據網絡環境購買并部署云消息隊列 Kafka 版服務：
步驟一：創建Topic
在概覽頁面的資源分布區域，選擇地域。
重要Topic需要在應用程序所在的地域（即所部署的ECS的所在地域）進行創建。Topic不能跨地域使用。例如Topic創建在華北2（北京）這個地域，那么消息生產端和消費端也必須運行在華北2（北京）的ECS。
在實例列表頁面，單擊目標實例名稱。
在左側導航欄，單擊Topic 管理。
在Topic 管理頁面，單擊創建 Topic。
在創建 Topic面板，設置Topic屬性，然后單擊確定。
參數
說明
示例
名稱
Topic名稱。
demo
描述
Topic的簡單描述。
demo test
分區數
Topic的分區數量。
12
存儲引擎
說明當前僅專業版實例支持選擇存儲引擎類型，標準版暫不支持，默認選擇為云存儲類型。
Topic消息的存儲引擎。
云消息隊列 Kafka 版支持以下兩種存儲引擎。
云存儲：底層接入阿里云云盤，具有低時延、高性能、持久性、高可靠等特點，采用分布式3副本機制。實例的規格類型為標準版（高寫版）時，存儲引擎只能為云存儲。
Local 存儲：使用原生Kafka的ISR復制算法，采用分布式3副本機制。
云存儲
消息類型
Topic消息的類型。
普通消息：默認情況下，保證相同Key的消息分布在同一個分區中，且分區內消息按照發送順序存儲。集群中出現機器宕機時，可能會造成消息亂序。當存儲引擎選擇云存儲時，默認選擇普通消息。
分區順序消息：默認情況下，保證相同Key的消息分布在同一個分區中，且分區內消息按照發送順序存儲。集群中出現機器宕機時，仍然保證分區內按照發送順序存儲。但是會出現部分分區發送消息失敗，等到分區恢復后即可恢復正常。當存儲引擎選擇Local 存儲時，默認選擇分區順序消息。
普通消息
日志清理策略
Topic日志的清理策略。
當存儲引擎選擇Local 存儲（當前僅專業版實例支持選擇存儲引擎類型為Local存儲，標準版暫不支持）時，需要配置日志清理策略。
云消息隊列 Kafka 版支持以下兩種日志清理策略。
Delete：默認的消息清理策略。在磁盤容量充足的情況下，保留在最長保留時間范圍內的消息；在磁盤容量不足時（一般磁盤使用率超過85%視為不足），將提前刪除舊消息，以保證服務可用性。
Compact：使用Kafka Log Compaction日志清理策略。Log Compaction清理策略保證相同Key的消息，最新的value值一定會被保留。主要適用于系統宕機后恢復狀態，系統重啟后重新加載緩存等場景。例如，在使用Kafka Connect或Confluent Schema Registry時，需要使用Kafka Compact Topic存儲系統狀態信息或配置信息。
重要Compact Topic一般只用在某些生態組件中，例如Kafka Connect或Confluent Schema Registry，其他情況的消息收發請勿為Topic設置該屬性。具體信息，請參見云消息隊列 Kafka 版Demo庫。
Compact
標簽
Topic的標簽。
demo
創建完成后，在Topic 管理頁面的列表中顯示已創建的Topic。
步驟二：創建Group
在概覽頁面的資源分布區域，選擇地域。
在實例列表頁面，單擊目標實例名稱。
在左側導航欄，單擊Group 管理。
在Group 管理頁面，單擊創建 Group。
在創建 Group面板的Group ID文本框輸入Group的名稱，在描述文本框簡要描述Group，并給Group添加標簽，單擊確定。
創建完成后，在Group 管理頁面的列表中顯示已創建的Group。
相關文檔
若您不想手動創建Topic和Group，可以開啟自動創建Topic和Group功能，請參見自由使用Group和自動創建Topic。
若您希望通過API創建資源，請參見CreateTopic - 創建Topic和CreateConsumerGroup - 創建消費組。
創建資源后，可以根據網絡環境使用SDK收發消息，請參見步驟四：使用SDK收發消息。