[聚合文章] Spring Boot集成Kafka

前提介绍

由于公司使用了微服务架构，很多业务拆成了很多小模块。
有个场景是这样的A服务主要负责写入或者修改数据库中的数据，B服务主要负责读取，B服务使用缓存技术，当A发生了修改后，需要通知B来清除缓存。
中间两个服务之间通知使用了Kafka，这个是本篇文章主要介绍的，关于 缓存技术 我也简单介绍过。

Kafka

简介

Kafka官网

Kafka is a distributed,partitioned,replicated commit logservice。它提供了类似于JMS的特性，但是在实现上完全不同，此外它并不是JMS规范的实现。
kafka对消息保存时根据Topic进行归类，发送消息者成为Producer,消息接受者成为Consumer,此外kafka集群有多个kafka实例组成，每个实例成为broker。
无论是kafka集群，还是producer和consumer都依赖于zookeeper来保证系统可用性集群保存一些meta信息。