集成和简单生产消费流程
一、引入依赖
二、配置文件中配置Kafka
将来我们的项目大概率不会是会都扮演生产者和消费者两个角色，所以在集成Kafka的时候，生产者的项目中只配置生产者相关的配置即可，消费者项目配置消费者的相关的配置即可
三、编写生产者代码
为了简化演示，直接将业务层代码写到了控制层，见谅哈！
四、编写消费者
注意：如果不调用手动提交offset这个方法，那么会产生消息重复消费的问题
五、调用生产者的接口，观察消费者是否正常消费到消息
1、调用生产者接口
2、观察控制台消费者
可以看到生产者发送了消息，消费者立刻就拿到了消息！
消费消息细节配置
一、指定Broker的主题和分区，控制消费者数量和消费偏移量
二、在配置文件中配置监听的配置
一般listener都得在配置文件中进行配置，推荐使用下图中的配置方式，搭配上面业务代码中手动提交offset。
这样的优势是消费者每处理1条消息，就更新offset。而不是一次性poll500条消息，等待都处理完才提交offset
至此，关于Springboot集成Kafka介绍完毕，详细的配置后续还会持续的更新，希望大家能够持续关注！
本文转载自: https://blog.csdn.net/CNpeaceful/article/details/135654094
版权归原作者 Be explorer 所有， 如有侵权，请联系我们删除。
版权归原作者 Be explorer 所有， 如有侵权，请联系我们删除。