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