Apache Flink 的迁移之路，2 年处理效果提升 5 倍
在 2017 年上半年以前，TalkingData 的 App Analytics 和 Game Analytics 两个产品，流式框架使用的是自研的 td-etl-framework。该框架降低了开发流式任务的复杂度，对于不同的任务只需要实现一个 changer 链即可，并且支持水平扩展，性能尚可，曾经可以满足业务需求。
RabbitMQ：四种ExChange用法
RabbitMQ发送消息时，都是先把消息发送给ExChange（交换机），然后再分发给有相应RoutingKey（路由）关系的Queue（队列）。ExChange和Queue之前是多对多的关系。RabbitMQ 3.0之后创建ExChange时，有四种类型可选“fanout、direct、topic、headers”。
SpringBoot开发案例之整合Kafka实现消息队列
前言
最近在做一款秒杀的案例，涉及到了同步锁、数据库锁、分布式锁、进程内队列以及分布式消息队列，这里对SpringBoot集成Kafka实现消息队列做一个简单的记录。
Kafka简介
Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。