SpringBoot Kafka 整合使用

前提

假设你了解过 SpringBoot 和 Kafka。

1、SpringBoot

如果对 SpringBoot 不了解的话，建议去看看DD 大佬和纯洁的微笑的系列博客。

2、Kafka

Kafka 的话可以看看我前两天写的博客 ：Kafka 安装及快速入门学习的话自己开台虚拟机自己手动搭建环境吧，有条件的买服务器。

注意：一定要亲自自己安装实践，接下来我们将这两个进行整合。

创建项目项目整体架构：

使用 IDEA 创建 SpringBoot 项目，这个很简单了，这里不做过多的讲解。

1、pom 文件代码如下：

主要引入了 spring-kafka 、lombok 、 gson 依赖。

2、消息实体类 Message.java 如下：

3、消息发送类 KafkaSender.java

就这样，发送消息代码就实现了。

这里关键的代码为 方法， 是 Kafka 里的 topic ，这个 topic 在 Java 程序中是不需要提前在 Kafka 中设置的，因为它会在发送的时候自动创建你设置的 topic， 是消息内容，这里暂时先说这么多了，不详解了，后面有机会继续把里面源码解读写篇博客出来（因为中途碰到坑，老子跟了几遍源码）。

4、消息接收类 KafkaReceiver.java

客户端 consumer 接收消息特别简单，直接用 注解即可，并在监听中设置监听的 ， 是一个数组所以是可以绑定多个主题的，上面的代码中修改为 就可以同时监听两个 的消息了。需要注意的是：这里的 topic 需要和消息发送类 KafkaSender.java 中设置的 topic 一致。

5、启动类 KafkaApplication.java

6、配置文件 application.properties

如果你只是简单整合下，其他的几个默认就好了。

Kafka 设置

在你安装的 Kafka 目录文件下：

启动 zk

使用安装包中的脚本启动单节点 Zookeeper 实例：

启动 Kafka 服务

使用 启动 kafka 服务：

启动成功后！

千万注意： 记得将你的虚拟机或者服务器关闭防火墙或者开启 Kafka 的端口 9092。

运行

出现这就代表整合成功了！

我们看下 Kafka 中的 topic 列表就

就会发现刚才我们程序中的 已经自己创建了。

最后

转载请务必注明原创地址为：http://www.54tianzhisheng.cn/2018/01/05/SpringBoot-Kafka/