阿里云上的 Confluent 消息流服务
阿里云与 Confluent 合作，提供基于 Apache Kafka 的消息流解决方案，使您能够以连续、实时的流形式轻松访问、存储和管理消息。 您可以享受 Kafka 的所有企业级功能，无需繁琐的管理和监控工作，并能实时、大规模地处理、过滤、分析和回应消息流，同时享有企业级安全。 Confluent 消息流服务应用在多个行业广泛的用例中，包括金融服务、全渠道零售、自动驾驶汽车制造、欺诈检测、微服务和物联网设备等。
产品优势
-
完全托管的 Kafka 消息流服务
借助阿里云高度可扩展且安全的云环境，享受 Kafka 的企业级消息流能力，包括丰富的连接器生态系统、CI/CD 容器集成和交付，以及 DevOps 自动化。
-
高集群可扩展性和性能
通过将消息持久化并落盘，云消息队列 Confluent 版面对海量消息堆积也能维持集群的高吞吐性能。 全自动巡检运维系统使得服务的可用性达到99.9%。
-
简单且高性价比的操作
提供核心链路健康巡检，集群自动诊断；每个消费组可针对消息堆积量设置监控告警；提供完备的管控 OpenAPI，实现各类资源管理和运维。
-
专业支持 Kafka
世界顶级 Kafka 专家的专业知识和全天候支持，让您的应用程序保持可扩展性，并在整个开发生命周期中避免潜在问题。
-
Apache Kafka 原厂商业化产品
Confluent 以其在数据流处理领域的领先技术和作为创始团队对 Apache Kafka 项目80%的代码贡献为基础，深度优化了 Kafka 技术，构建安全且可靠的企业级流处理平台。
-
开箱即用，无缝迁移
全托管 Confluent Platform，无需搭建，即开即用；无缝迁移现有业务，代码零修改，大幅降低迁移成本和技术风险，轻松享有弹性和高可用优势。
产品功能
多语言开发
支持多种主流编程语言进行软件开发，例如 Java、Python 和 Scala
丰富的内置生态系统
企业级 Connectors，MQTT 代理，Schema Registry
全兼容 Apache Kafka
基于 Apache Kafka 核心能力构建，并保持对其的兼容性
消息流数据库 KsqlDB
基于轻量级 SQL 的事件流数据库，极大简化流处理应用的构建
云资源弹性扩展能力
灵活、弹性的计算和存储资源
企业级安全能力
支持 SSL、RBAC 和外部 LDAP
企业级解决方案售后支持
阿里云与 Confluent 提供全天候 24 x 7 x 365 专业服务支持
阿里云产品集成互联互通
阿里云实时计算 Flink版、E-MapReduce 等平台进行数据消费和分布式计算
Confluent 消息流服务工作原理
您面临的挑战
分布式应用程序、数据存储、系统和海量数据给数据分析获取及时洞察带来挑战。 僵化的数据架构会导致不必要的前期成本、应用程序滞后或停机。
我们的解决方案
-
该解决方案利用 Apache Kafka 提供流处理和实时消息提取、转换和加载（ETL）功能，以支持相关的、及时的分析和商业智能应用程序。
阿里云 Kubernetes 环境中的 Kafka 提供了企业级功能（例如 Control Center）以改善集群监控和DevOps。 它还提供了基于角色的访问控制（RBAC）安全模型和轻型目录访问协议（LDAP）以保证企业安全。
KsqlDB 帮助您构建基于 Apache Kafka 的事件流应用程序。 连接器跨越整个生态系统，为 SaaS 平台、应用程序、设备以及数据库提供安全高效的数据访问。
Schema Registry 实施一致的数据格式、集中策略以及数据治理，以提高数据存储效率和数据流性能。
支持场景
通用数据流动性
Confluent 提供跨多个云服务和本地环境的数据集成、实时数据流处理和分析能力，并确保数据在混合云环境中的一致性和高可用性。通过一致的操作界面与体验，简化混合云环境中的操作管理。
人工智能
AI 模型数据的质量和实时性对模型的有效性至关重要。Confluent在 AI 模型应用场景中的作为数据流平台，通过确保数据的实时性、相关性、管控和信任度来支持 AI 系统和应用程序的规模化生产与交付。
客户洞察与体验优化
整合来自不同源的实时数据流，去标识化地处理和分析数据，为企业提供全面、实时、统一的客户数据视图。Confluent 支持构建事件驱动的应用，可实时响应客户互动行为，提供个性化服务和体验。
事件驱动型微服务
通过松耦合的微服务架构，实现更大的敏捷性和更快的创新。使用 Confluent 彻底解耦的微服务，统一服务间的通信标准，并消除维护独立数据状态的需求。
产品版本
| 项目 | 专业版 Professional | 企业版 Enterprise |
|---|---|---|
| 环境部署 | Stage/Product | Stage/Product |
| 跨可用区部署 | 多可用区 | 多可用区 |
| Schema Registry | 支持 | 支持 |
| KsqlDB | 支持 | 支持 |
| Connector | OpenSource Connectors | All Connectors |
| KafkaRestProxy | 支持 | 支持 |
| Cluster Linking | 作为数据源支持 | 作为数据源与目的地支持 |
| Schema Linking | 支持 | 支持 |
| 用户管理 | 系统自带 LDAP | 系统自带 LDAP / 自定义 LDAP |
| 认证方式 | SASL_SSL | SASL_SSL |
| 权限管理 | ACL & RBAC | ACL & RBAC |
| Exactly Once 语义 | 支持 | 支持 |
| 基于密钥的存储压缩 | 支持 | 支持 |
| 图形化管理界面 | 支持 | 支持 |
| 业务指标（Prometheus 格式） | 支持 | 支持 |
| 日志集成 SLS | 支持 | 支持 |
| Support | 普通支持答疑 | 原厂一对一服务 |
| 服务保障 | 99.9% | 99.9% |
与 Confluent 合作
Confluent 是一家专注动态数据技术的公司。 Confluent 的云原生平台正在成为现代企业基础架构的一部分。 该平台旨在释放实时消息的能力，并在企业中充当中枢神经系统，让企业能够围绕实时消息流连接其所有应用程序，并对业务中发生的一切做出智能反应和响应。 Confluent 和阿里云之间的合作伙伴关系使得组织能在稳健和安全的云环境中，充分利用持续流动的消息，以在现代数字世界中创新和取得成功。
