0.在使用Spiringboot集成Kafka之前需要将kafka的服务端程序（包括jre、zookeeper、kafka三部分）安装好。
1.创建Springboot项目，在Spring Initializer中选择上kafka和kafka Stream的依赖项（不管有没有用先都选上）。
2.Kafka Producer的配置和使用：
首先时Kafka的配置文件：
然后是生产者发送数据的部分，这里将发送数据的部分放在控制器中，以方便测试，其中发送数据的核心代码是这一句：kafkaTemplate.send("topic_name", msg);
3.Kafka Consumer的配置和使用：
首先是消费者的配置文件：
然后是消费者接收数据的部分：
4.让程序跑起来：在使用java进行kafka操作之前需要依次将zookeeper和kafka启动，并且新建消息推送的topic（本文topic是“topic_name”），启动kafka消费者端和生产者端，注意消费者和生产者指定的topic要一致，在生产者的控制器发送一条数据，消费者的listen方法就能够接收到了。
参考文章：https://docs.spring.io/spring-kafka/reference/htmlsingle/#_with_java_configuration
