boisde / aliware-kafka-demos Goto Github PK

这里提供各种接入 Aliware Kafka 的demo，方便开发者快速上手。 目前客户端demo包括 Java，Python，Go，PHP，Logstash，SpringCloud，其它客户端暂时请参照已有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都需要在对应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授权策略