介绍 Kafka

Kafka 是一款基于发布与订阅的消息系统。

用生产者客户端 API 向 Kafka 生产消息，用消费者客户端 API 从 Kafka 读取这些消息。

引言

一、Kafka的Producer小案例

假设我们现在有一个电商系统，凡是能登录系统的用户都是会员，会员的价值体现在，消费了多少钱，就会累计相应的积分。积分可以兑换礼品包，优惠券···等等。

又到了我们的画图时间。首先我们得先来一个订单系统，那这个订单系统中肯定就会有数据日志产生，它现在就是把这些日志写到Kafka里面，日志我们使用json的方式记录。图中的statement表示订单状态，此时是已支付。

此时担任我们消费者的肯定就是会员系统了，它要对这个id为1的会员进行积分累计。当然必须要考虑到的情况是，这个会员有可能也会进行退款操作，那相应的积分也会减少。statement此时为cancel取消

Kafka 是目前非常主流的一款 MQ 产品，很多开发人员都使用过，实际场景中经常被用来做系统解耦、消息补偿、日志收集等。如果从零开始写一个生产者、消费者该怎么写呢？安哥写了个 Demo，先不管原理机制，跑通再说。