从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、最终显示效果如下:消息准实时消费
从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、最终显示效果如下:消息准实时消费