●一致性:生产者的消息确认、消费者的幂等性、Broker的数据同步;
●可用性:数据如何保证不丢不重、数据如何持久化、持久化时如何读写;
●分区容错:采用何种选举机制、如何进行多副本同步;
●海量数据:如何解决消息积压、海量Topic性能下降;
性能上,可以借鉴时间轮、零拷贝、IO多路复用、顺序读写、压缩批处理。

●一致性:生产者的消息确认、消费者的幂等性、Broker的数据同步;
●可用性:数据如何保证不丢不重、数据如何持久化、持久化时如何读写;
●分区容错:采用何种选举机制、如何进行多副本同步;
●海量数据:如何解决消息积压、海量Topic性能下降;
性能上,可以借鉴时间轮、零拷贝、IO多路复用、顺序读写、压缩批处理。