使用SpringBoot搭建基础的Kafka流处理平台

文章目录

一、调试并启动项目

(1)在(https://github.com/skykip/kafka_rgzn_Training)下载项目

(2)调试项目,设置项目结构

(3)启动项目

二、代码详细注释

(1)ErrorCode

(2)MessageEntity

(3)Response

(4)KafkaConsumerConfig

(5)KafkaProducerConfig

(6)SimpleConsumer

(7)ProducerController

(8)ProducerCallback

(9)SimpleProducer

(10)KafkaDemoApplication

(11)application.properties

三、调试KafkaDemoApplication文件

​ A. 测试时,使用get测试http://localhost:8080/kafka/index接口是否正常。发送相应的json数据。请截图Http接口调试工具中响应体的具体内容和项目运行界面的显示内容。如下图所示:

​ B. 测试时,使用post方式向http://localhost:8080/kafka/send接口发送json数据。

​ 样例数据如下(请在样例数据中改为自己的姓名和学号):

​ {“title”:”bigdata19-kafka”,”body”:”2022-06-07,俞佳杭(194800234)的kafka实训”}

​ 请截图Http接口调试工具中响应体的具体内容和项目运行界面的显示内容。如下图所示:

​ C.测试后,项目运行界面的显示内容