Geo-Replication
MirrorMaker 可以把消息复制到多个数据中心或者云区域
生产者负责把消息推送到指定的分区(patition), 和消息
消费者可以分组
同分组的消费者会一load...- 消费者看到消息的顺序与日志的顺序一致
- 假如有N台消息服务器 , kafka能容忍宕机了N-1台服务器并且不会丢失数据
kafka 是一个消息系统, 存储系统, 流处理系统
作为消息系统,...优点: 多个消费者可以快速消费消息
缺点: 不支持多个消费者消费统一个消息, 消息被消费完以后就会小时
发布与订阅(publish-subscribe)
生产者广播消息给每一个消费者....优点: 消息可以同时被多个消费者消费
缺点:消息处理慢, 一次只能消费一个消息
kafka 的消费者组(consumer group)泛化了这两种消息队列, 一个消费者组就是queue, 订阅是跨消费者组的...不管服务器上有数据上50K,还是50T, 写入性能是一样的
kafka 存储系统设计原理
作为流处理系统, kafka的特点与优势
可以使用生产者与消费者api来处理, 但是更复杂的流可以使用kafka