kafka和nsq相关整理

kafka 一个topic多个partition，一个partition一主多从，leader承担所有的读写，然后同步到follower。 老版本producer/consumer需要直接和zk交互，新版本直接和broker交互，因为zk写性能不好。 producer内部维护内存队列，异步一定间隔或数量发送到broker，失败的话，默认重试3次；同步发送，需要实时调用flush。 每个partit

>>阅读原文<<