使用Kafka客戶端
更新時間 2024-03-31 18:57:14
最近更新時間: 2024-03-31 18:57:14
分享文章
本章節主要介紹使用Kafka的操作指導。
操作場景
用戶可以在集群客戶端完成Topic的創建、查詢、刪除等基本操作。
前提條件
已安裝客戶端，例如安裝目錄為“/opt/hadoopclient”，以下操作的客戶端目錄只是舉例，請根據實際安裝目錄修改。
使用Kafka客戶端
-
安裝客戶端，具體請參考安裝客戶端章節。
-
登錄安裝客戶端的節點。
-
執行以下命令，切換到客戶端目錄，例如：
cd /opt/hadoopclient/Kafka/kafka/bin -
執行以下命令，配置環境變量。
source /opt/hadoopclient/bigdata_env -
集群默認已啟用Kerberos認證，執行以下命令認證當前用戶。
kinit Kafka 用戶 -
創建一個Topic。
sh kafka-topics.sh --create --topic 主題名稱--partitions 主題占用的分區數 --replication-factor 主題的備份個數 --zookeeper ZooKeeper角色實例所在節點IP地址:clientPort/kafka -
執行以下命令，查詢集群中的Topic信息。
sh kafka-topics.sh --list --zookeeper ZooKeeper角色實例所在節點IP地址:clientPort/kafka -
刪除創建的Topic。
sh kafka-topics.sh --delete --topic 主題名稱 --zookeeper ZooKeeper角色實例所在節點IP地址:clientPort/kafka輸入 "y"，回車。
