操作場景
用戶可以在集群客戶端完成Topic的創建、查詢、刪除等基本操作。
前提條件
已安裝客戶端，例如安裝目錄為“/opt/hadoopclient”，以下操作的客戶端目錄只是舉例，請根據實際安裝目錄修改。
使用Kafka客戶端（MRS 3.x之前版本）
- 進入ZooKeeper實例頁面：
單擊集群名稱，登錄集群詳情頁面，選擇“組件管理 > ZooKeeper > 實例”。
說明若集群詳情頁面沒有“組件管理”頁簽，請先完成IAM用戶同步（在集群詳情頁的“概覽”頁簽，單擊“IAM用戶同步”右側的“同步”進行IAM用戶同步）。
- 查看ZooKeeper角色實例的IP地址。
記錄ZooKeeper角色實例其中任意一個的IP地址即可。
- 登錄安裝客戶端的節點。
- 執行以下命令，切換到客戶端目錄，例如“/opt/hadoopclient/Kafka/kafka/bin”。
cd /opt/hadoopclient/Kafka/kafka/bin
- 執行以下命令，配置環境變量。
source /opt/hadoopclient/bigdata_env
- 如果當前集群已啟用Kerberos認證，執行以下命令認證當前用戶。如果當前集群未啟用Kerberos認證，則無需執行此命令。
kinit Kafka用戶
- 創建一個Topic：
sh kafka-topics.sh --create --topic 主題名稱 --partitions主題占用的分區數 --replication-factor主題的備份個數 --zookeeper ZooKeeper角色實例所在節點IP 地址 : clientPort /kafka
例如：sh kafka-topics.sh --create --topic TopicTest--partitions 3--replication-factor 3 --zookeeper 10.10.10.100:2181/kafka
- 執行以下命令，查詢集群中的Topic信息：
sh kafka-topics.sh --list --zookeeper ZooKeeper角色實例所在節點IP 地址:clientPort /kafka
例如：sh kafka-topics.sh --list --zookeeper 10.10.10.100:2181/kafka
- 刪除7中創建的Topic：
sh kafka-topics.sh --delete --topic主題名稱 --zookeeper ZooKeeper角色實例所在節點IP 地址 : clientPort /kafka
例如：sh kafka-topics.sh --delete --topic TopicTest --zookeeper 10.10.10.100:2181/kafka
輸入"y"，回車。
使用Kafka客戶端（MRS 3.x及之后版本）
- 進入ZooKeeper實例頁面：
登錄FusionInsight Manager，具體請參見訪問FusionInsight Manager（MRS 3.x及之后版本）。然后選擇“集群 > 待操作的集群名稱 > 服務 > ZooKeeper > 實例”。
- 查看ZooKeeper角色實例的IP地址。
記錄ZooKeeper角色實例其中任意一個的IP地址即可。
- 登錄安裝客戶端的節點。
- 執行以下命令，切換到客戶端目錄，例如“/opt/hadoopclient/Kafka/kafka/bin”。
cd /opt/hadoopclient/Kafka/kafka/bin
- 執行以下命令，配置環境變量。
source /opt/hadoopclient/bigdata_env
- 如果當前集群已啟用Kerberos認證，執行以下命令認證當前用戶。如果當前集群未啟用Kerberos認證，則無需執行此命令。
kinit Kafka用戶
- 登錄FusionInsight Manager，選擇“集群 > 待操作的集群名稱 > 服務 >ZooKeeper > 配置 > 全部配置”，搜索參數“clientPort”,記錄“clientPort”的參數值。
- 創建一個Topic：
sh kafka-topics.sh --create --topic 主題名稱 --partitions主題占用的分區數 --replication-factor主題的備份個數 --zookeeper ZooKeeper角色實例所在節點IP 地址 : clientPort /kafka
例如：sh kafka-topics.sh --create --topic TopicTest--partitions 3--replication-factor 3 --zookeeper 10.10.10.100:2181/kafka
- 執行以下命令，查詢集群中的Topic信息：
sh kafka-topics.sh --list --zookeeper ZooKeeper角色實例所在節點IP 地址:clientPort /kafka
例如：sh kafka-topics.sh --list --zookeeper 10.10.10.100:2181/kafka
- 刪除步驟8中創建的Topic：
sh kafka-topics.sh --delete --topic主題名稱 --zookeeper ZooKeeper角色實例所在節點IP 地址 : clientPort /kafka
例如：sh kafka-topics.sh --delete --topic TopicTest --zookeeper 10.10.10.100:2181/kafka
