从GitEE上下载了一个kafkaUI界面jar包----kafkaUI.jar

将jar包上传到kafka集群服务器/opt/目录下

1、kafkaUI配置界面启动：

执行启动指令：

[root@hadoop2 opt]#  java -Dhosts=192.168.0.12 -jar kafkaUI.jar

启动成功页面如图所示：

2、配置

3、管理

4、操作

5、生产者配置

6、消费者配置

7、最终显示效果如下：消息准实时消费