一、接口回调+自定义分区 　　1.接口回调：在使用消费者的send方法时添加Callback回调 /** * @author: PrincessHug * @date: 201 ...

一、Kafka概述 　　1.Kafka是一个分布式流媒体平台，它有三个关键功能： 　　　(1)发布和订阅记录流，类似于消息队列或企业消息传递系统； 　　　(2)以容错的持久方式存储记录流； ...