Kafka(华为FusionInsight )操作命令

华为大数据kafka操作
web界面创建角色、用户。用户管理角色
进入服务器环境，进入客户端目录/opt/hadoopclient，导入环境变量source bigdata_env。
切换用户kinit kafka用户（kafka_test）

1. 查看当前集群Topic列表。

   ZooKeeper集群IP:24002/kafka>

2. 查看单个Topic详细信息。

   <Topic名称>

3. 删除Topic，由管理员用户操作。

   <Topic名称>

4. 创建Topic，由管理员用户操作。

   <Topic名称>

5. “True”。

   --old-producer -sync

6. “True”。

   --from-beginning

7. 赋Consumer权限命令，由管理员用户操作。

   <消费者组名称>

8. 赋Producer权限命令，由管理员用户操作。

   <Topic名称>

9. New Producer API生产消息，需要拥有该Topic生产者权限。

   --producer.config config/producer.properties

10. New Consumer API消费数据，需要拥有该Topic的消费者权限

    集群IP:21007> --new-consumer --consumer.config config/consumer.properties