这里提供各种接入 Aliware Kafka 的demo,方便开发者快速上手。 目前客户端demo包括 Java,Python,Go,PHP,Logstash,SpringCloud,其它客户端暂时请参照已有demo自行调试,后续会陆续完善。
- Kafka服务端版本是0.10,Client版本建议0.10
- 使用之前需要先申请Topic(类型选择Kafka消息)与ConsumerID,详情请参考申请MQ资源
- 如果没有申请Topic与ConsumerID,则会直接导致鉴权失败
- 欢迎加钉钉群咨询,用钉钉扫描群二维码
- 各类客户端的详细接入请参考具体仓库目录,如kafka-java-demo
- 附各region域名列表(bootstrap.servers)
Region | 域名 |
---|---|
公网 | kafka-ons-internet.aliyun.com:8080 |
华东1 | kafka-cn-hangzhou.aliyun.com:8080 |
华北2 | kafka-cn-beijing.aliyun.com:8080 |
华东2 | kafka-cn-shanghai.aliyun.com:8080 |
华南1 | kafka-cn-shenzhen.aliyun.com:8080 |
注意:除了公网,其它Region都需要在对应Region的ECS上面访问;比如华东1的topic,需要在华东1的ECS上面才能访问;
-
无缝迁移:完全兼容开源Kafka的协议,无需修改代码,即可从自建Kafka迁移至阿里云Kafka
-
安全防护:Aliware MQ 提供的 Kafka 消息服务利用 SASL 机制对用户身份进行认证,并利用 SSL 对通道进行加密,提供更加安全的消息服务。
-
高可靠/高可用:消息持久化落盘到消息队列,支持多副本以及主备自动切换,可靠性达99.99999999%,服务可用性高达99.9%。
-
高性能:支持万级 Topic,以及海量的消息堆积的情况下,也始终保持超高的性能。
-
统一运维:提供一整套包括资源申请、资源授权、消息堆积查询等运维服务,提升用户的产品体验。
-
免费试用:Kafka 企业级消息服务于 2017.03.15 开放公测,公测期间不收取API调用费,仅仅收取topic资源占用费,每个topic每天2元。
主子账号,建议使用RAM授权策略