操作场景

用户可以在集群客户端完成Topic的创建、查询、删除等基本操作。

前提条件

已安装客户端，例如安装目录为“/opt/hadoopclient”，以下操作的客户端目录只是举例，请根据实际安装目录修改。

使用Kafka客户端

1. 安装客户端，具体请参考安装客户端章节。

2. 登录安装客户端的节点。

3. 执行以下命令，切换到客户端目录，例如：

   cd /opt/hadoopclient/Kafka/kafka/bin
   

4. 执行以下命令，配置环境变量。

   source /opt/hadoopclient/bigdata_env
   

5. 集群默认已启用Kerberos认证，执行以下命令认证当前用户。

   kinit Kafka 用户
   

6. 创建一个Topic。

   sh kafka-topics.sh --create --topic 主题名称--partitions 主题占用的分区数 --replication-factor 主题的备份个数 --zookeeper ZooKeeper角色实例所在节点IP地址:clientPort/kafka
   

7. 执行以下命令，查询集群中的Topic信息。

   sh kafka-topics.sh --list --zookeeper ZooKeeper角色实例所在节点IP地址:clientPort/kafka
   

8. 删除创建的Topic。

   sh kafka-topics.sh --delete --topic 主题名称 --zookeeper ZooKeeper角色实例所在节点IP地址:clientPort/kafka
   

   输入 "y"，回车。