文章目录
一、调试并启动项目
(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.测试后,项目运行界面的显示内容