Skip to content

boisde/aliware-kafka-demos

 
 

Repository files navigation

Aliware Kafka Demos

这里提供各种接入 Aliware Kafka 的demo,方便开发者快速上手。 目前客户端demo包括 JavaPythonGoPHPLogstashSpringCloud,其它客户端暂时请参照已有demo自行调试,后续会陆续完善。

接入说明

  1. Kafka服务端版本是0.10,Client版本建议0.10
  2. 使用之前需要先申请Topic(类型选择Kafka消息)与ConsumerID,详情请参考申请MQ资源
  3. 如果没有申请Topic与ConsumerID,则会直接导致鉴权失败
  4. 欢迎加钉钉群咨询,用钉钉扫描群二维码
  5. 各类客户端的详细接入请参考具体仓库目录,如kafka-java-demo
  6. 附各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授权策略

About

提供各种客户端接入Aliware Kafka的demo工程

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Java 34.1%
  • JavaScript 25.5%
  • Go 20.3%
  • Python 8.6%
  • PHP 7.9%
  • Groovy 1.9%
  • Shell 1.7%