1、引入springboot-kafka的jar包依赖。
2、在application.properties添加配置信息，本机安装的kafka的ip和端口号，9092默认端口。消费者的组名称。
3、创建生产者服务，声明成spring组件，注入KafkaTemplate，send方法的第一个参数是topic的名称，第二个参数是数据。
4、创建消费者服务，开启监听，如果获取到数据，则输出接受到的数据。
5、创建restController，调用生产者，往kafka发送4个消息。
6、启动zookeeper服务，点击zkServer运行。
7、启动kafka：kafka-server-start.bat ..\..\config\server.properties，注意进入.bat所在的当前目录下启动
8、启动项目，请求kafkaSender，返回success。
9、查看日志：发现接收到了消息。
转载网址：https://jingyan.baidu.com/article/fec4bce293d231f2608d8b55.html