阿里云消息队列Kafka优势和功能

灵活高效
 
提供多种消息类型支持,无任何强制绑定其他产品,100%兼容开源社区,业务代码无需任何改造,可平滑切到阿里云Kafka
 
高扩展性
 

Kafka为分布式系统,易于向外扩展,消息队列支持集群规模的热扩展,另外所有的 producer、consumer 均为分布式的,无需停机即可扩展机器。
 
高性能

 
Kafka在数据发布和订阅过程中都能保证数据的高吞吐量,即便在TB级数据存储的情况下,仍然能保证稳定的性能。
 
高可靠
 
Kafka是一个具有分区机制、副本机制和容错机制的分布式消息系统
 
高安全
 
提供阿里云标准的AK/SK身份认证和ACL权限控制, 不同租户之间网络隔离,实例的网络访问在账户间天然隔离,确保数据不被窃取或篡改,保证用户数据的安全
 
异步通信
 
消息的发送者将消息发送到消息队列后可以立即返回,不用等待接收者的响应。消息会被保存在队列中,直到被接收者取出。消息的发送与处理是完全异步的。
 
进程解耦
 
消息队列帮助减少两个进程间的耦合度。只要消息格式不变,即使接收者的接口、位置或者配置改变,也不会给发送者带来任何改变。并且,消息发送者无需知道消息接收者是谁,使得系统设计更清晰;相反的,进程间使用远程过程调用(RPC)或者socket连接,当一方接口、ip或端口改变了,另一方则必须修改改写请求配置。
 
消息路由

 
发送者无需与接收者建立直接连接,双方通过消息队列保证消息能够从发送者路由到接收者,甚至对于本来网络不易互通的两个服务,也可以提供消息路由。
 
多终端
 
用户系统的多个部分可以同时发送或接收消息,通过消息状态来进行消息可用性的控制。

Kafka功能点
 
流式数据处理:海量数据处理,高吞吐,低延迟
 
消息订阅和发布:支持消息订阅和发布
 
消息存储:提供一个复杂度为0的磁盘结构存储数据
 
横向扩张:支持扩展,可平滑横向扩展
 
分布式:支持消息分区,每个分区有序
 
消费方式:支持广播消费,集群消费,顺序消费
 
多语言SDK 支持:客户端支持java,c,js等多语言
 
Kafka 后台功能:
 
Topic管理:新建,删除,查询Topic信息
 
Consumer group管理:新建,查询Consumer信息