分布式消息服务Kafka

分布式消息服务Kafka 是一个分布式、高吞吐量、高可用的消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，是大数据生态中不可或缺的产品之一。

立即订购

管理控制台

产品文档

立即订购

管理控制台

产品文档

快捷入口

高可用性

支持消息持久化，多副本存储机制。副本间消息同步、异步复制，数据同步或异步落盘多种方式供您自由选择。Kafka实例支持跨AZ部署，代理部署在不同的AZ，进一步保障服务高可用

高安全性

利用SASL机制对用户身份进行认证，并利用SSL对通道进行加密传输，确保数据在传输过程中不被窃取或篡改，保证您的数据安全。还借助虚拟私有云（VPC）和安全组等加强网络访问控制

全托管

具备原生Kafka的所有消息处理特性。无需任何改造，即可迁移上云，不再需要专门部署、运维，只需专注业务本身

运维高效

提供多维度指标监控，支持消息查询、消息回溯以及消息数据过期自动删除

为什么选择天翼云分布式消息服务Kafka

多样弹缩能力，支持分区重平衡

支持磁盘/节点/规格在线扩缩容，分钟级完成，无需停服，支持伸缩后分区重平衡

全面监控管理，多维度细化运行指标

实时监测实例运行，覆盖实例、节点、Topic、Group、Connect维度，总计40+项监控

丰富产品规格，支持国产化芯片

面向不同场景提供单机和集群多种实例规格，兼容开源Kafka2.X、3.X内核版本，支持国产化芯片

全托管智能运维，提供多种巡检工具

内置实例/Topic/Group/主机等多维度自定义告警规则，提供CPU、磁盘、句柄数等Broker检测和Topic检测

多场景兼容，无忧升级云端业务

日志收集

流计算处理

多路转发

全屏查看

场景说明

Kafka适合作为"日志收集中心"，当日志数据发送到Kafka集群，对于业务是无侵入式。另外，Kafka消费端适合对接Hadoop/ODPS等离线仓库存储和Strom/Spark等实现实时在线分析；使用该产品，用户只需关注业务逻辑，无需做更多的额外开发，就能够实现系统统计、分析以及报表查询

实现功能

应用分析解耦：作为应用系统和分析系统的桥梁，实现应用解耦，降低系统复杂性
支持在线/离线分析系统：支持实时在线分析系统和类似于 Hadoop 的离线分析系统，高效可靠

建议搭配产品

弹性云主机

云日志服务

使用指南

产品介绍

什么是分布式消息服务Kafka 分布式消息服务Kafka产品规格分布式消息服务Kafka与开源自建对比分布式消息服务Kafka产品功能使用限制分布式消息服务Kafka常用术语解释分布式消息服务Kafka与天翼云其他服务关系

快速入门

分布式消息服务Kafka的创建Topic说明分布式消息服务Kafka创建消费组说明连接Kafka编译运行Demo Java工程

开发指南

开发指南概述-实例连接信息的收集、Kafka的API调用收集连接信息 Java语言开发环境搭建和客户端接入示例

用户指南

实例管理-查看、扩容、续订、修改配置参数等连接Kafka-配置网络连接、连接示例等监控信息-实例、Topic、消费者监控

最佳实践

使用MirrorMaker跨集群数据同步 Kafka业务迁移如何设置消息堆积数超过阈值时，发送告警短信/邮件

云选天翼，赋能多元业务上云

即刻上云，业务升级新起点

立即咨询

免费试用

智算服务

应用商城

合作伙伴

开发者

支持与服务

了解天翼云

分布式消息服务Kafka

多样弹缩能力，支持分区重平衡

全面监控管理，多维度细化运行指标

丰富产品规格，支持国产化芯片

全托管智能运维，提供多种巡检工具

活动

智算服务

应用商城

合作伙伴

开发者

支持与服务

了解天翼云

分布式消息服务Kafka

多样弹缩能力，支持分区重平衡

全面监控管理，多维度细化运行指标

丰富产品规格，支持国产化芯片

全托管智能运维，提供多种巡检工具