快速入门-分布式消息服务Kafka - 天翼云

分布式消息服务Kafka

产品简介

分布式消息产品选型

主子账号和IAM权限管理

其他服务的关系

计费说明

续费、到期与欠费

快速入门

创建消费组

编译运行Demo Java工程

配置必须的监控告警

用户指南

权限管理

创建用户并授权使用Kafka

创建Kafka自定义策略

连接Kafka

连接未开启SASL的Kafka实例

连接已开启SASL的Kafka实例

实例管理

主题管理

查看分区状态

修改分区平衡

消费组

消费组列表

新建消费组

重置消费位置

删除消费组

应用用户管理

创建应用用户

管理应用用户生产消费权限

消息查询

按点位查询

按时间查询

监控信息

消费者监控

服务端检测

API参考

调用前须知

如何调用API

信息的获取

基本签名流程

API

消费组

更新消费组订阅的主题

重置消费组指定主题的消费位置

创建消费组

删除消费组

查询消费组选择的主题

最佳实践

生产者实践

消费者实践

消费位点提交

消费位点重置

消息重复和消费幂等

消费阻塞以及堆积

提高消费速度

增加 Consumer 实例

增加消费线程

通过认证生产与消费加密主题的消息

使用MirrorMaker跨集群数据同步

Kafka业务迁移

如何提高消息处理效率

如何设置消息堆积数超过阈值时，发送告警短信/邮件

消息堆积最佳实践

业务过载最佳实践

业务数据不均衡最佳实践

开发指南

收集连接信息

常见问题

相关协议

天翼云分布式消息服务协议

分布式消息服务Kafka服务等级协议

帮助中心分布式消息服务Kafka 快速入门

入门指引
环境准备
创建Topic
购买实例
创建消费组
编译运行Demo Java工程
配置必须的监控告警