SpringBoot整合Kafka中间件，上篇

小编的上篇文章，介绍了Kafka的一些基本概念，这些概念对于理解和使用Kafka非常重要。学会了概念还不行，我们还要实战操作一下。接下来，小编就给大家演示如何快速搭建基于SpringBoot工程的Kafka消息生产者。

第一步、创建SpringBoot基础工程

工程名称: springboot-kafka-producer

工程类型: Maven 工程

第二步、编辑工程maven配置文件

添加Kafka工程依赖

pom.xml

第三步、创建一个消息实体类

这个消息实体类，只是作为演示使用。包含两个属性，一个UUID，一个日期。

消息实体类

第四步、创建消息生产者配置信息类

记得一定不要忘记添加@Configuration注解。

BOOTSTRAP_SERVERS_CONFIG值没有采用硬编码的形式，而是读取资源配置注入的方式。

这个类的最主要作用就是初始化了KafkaTemplate实例，消息的发送就是通过kafka模板实例完成的。

配置信息类

第五步、创建消息生产者业务类

这个类不是必须的，他只是对kafka模板实例做了一个封装，把发送消息的业务封装了起来，真正起到发送消息作用的，还是kafka模板实例。

消息生产业务类

第六步、创建消息生产者控制器类

这个类的作用，主要是通过Restful服务请求的方式创建消息类实例，然后通过调用消息生产者业务类，发送消息。

消息生产控制器

第七步、修改入口启动类

添加开启kafka注解@EnableKafka

入口启动类

第八步、修改工程资源配置文件

资源配置文件

第九步、开启zookeeper服务，开启kafka服务，执行消息消费监听

示例是windows版的，linux版的命令差不多，只不过是执行的sh脚本

开启zookeeper

启动kafka

监听消息消费

第十步、运行工程

工程启动成功后，通过浏览器，访问消息生产者Restful服务

访问Restful服务生产消息

查看消息消费监控台

消息监听消费成功

消息成功发送到了kafka服务器，并成功进行了消费

结束

下一篇，小编就给大家演示如何快速搭建基于SpringBoot工程的Kafka消息消费者。