1.mq要支持可伸缩，快速扩容。设计一个分布式的MQ,broker->topic->partition 每个partition放一个机器，存放一部分数据。如果资源不够，给topic增加partition，然后做数据迁移。
2.mq的消息要落盘，保证进程挂了数据丢失，顺序写，这样磁盘随机读写的寻址开销，磁盘顺序读写的性能很高，这就是kafak的思路。
3.mq高可用，多副本->leader&follewer->broker挂了重新选举对外提供服务
4.支持数据0丢失。
1.mq要支持可伸缩，快速扩容。设计一个分布式的MQ,broker->topic->partition 每个partition放一个机器，存放一部分数据。如果资源不够，给topic增加partition，然后做数据迁移。
2.mq的消息要落盘，保证进程挂了数据丢失，顺序写，这样磁盘随机读写的寻址开销，磁盘顺序读写的性能很高，这就是kafak的思路。
3.mq高可用，多副本->leader&follewer->broker挂了重新选举对外提供服务
4.支持数据0丢失。