KafkaMonitor 源码导入 idea看源码怎么启动?查看页面

版权声明:本文为博主原创文章遵循 版权协议,转载请附上原文出处链接和本声明

topic:每条发布到Kafka集群的消息都有一個类别这个类别被称为topic。(物理上不同topic的消息分开存储逻辑上一个topic的消息虽然保存于一个或多个broker上但用户只需指定消息的topic即可生产或消费数据而不必关心数据存于何处)。

broker:kafka集群包含一个或多个服务器这些服务器就叫做broker。

在用IntelliJ 编写Java代码前先要在服务器启动kafka和自带的zookeeper,本文在虚拟机上启动

kafka下载:从下载 ,解压在虚拟机(服务器)上

进入到kafka的解压目录:

// 监听服务器上的kafka是否有相关的消息发过来

【1】运行IntelliJ仩的DemoApplication之后,在虚拟机(服务器)上输入hi时不仅虚拟机上运行的测试消费者能收到,windows上的IntelliJ程序也能收到

【2】在浏览器上输入不仅intelliJ上的消费者能收到,在虚拟机(服务器)上运行的测试消费者也能收到:(其中8080是tomcat服务器的端口springboot默认下带的是tomcat)

虚拟机(服务器)上的效果:

最后显示一下pom.xml,这个文件一般都自动生成用来显示项目的依赖,我给出来的原因是给大家参考一下因为有时候代码一样,但环境错了也会导致运行鈈了:

 

我要回帖

更多关于 idea看源码 的文章

 

随机推荐