检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
pom.xml .\ maven配置文件，包含Kafka客户端引用。 打开IntelliJ IDEA，导入Demo。 Demo是一个Maven构建的Java工程，因此需要配置JDK环境，以及IDEA的Maven插件。 图1 选择“导入工程” 图2 选择“Maven” 图3 选择Java环境
权限管理 创建用户并授权使用DMS for Kafka
Java客户端接入示例 本文介绍Maven方式引入Kafka客户端，并完成Kafka实例连接以及消息生产与消费的相关示例。如果您需要在IDE中查看Demo具体表现，请查看Java开发环境搭建。 下文所有Kafka的配置信息，如实例连接地址、Topic名称、用户信息等，请参考收集连接信息获取。
流式数据传输、在线/离线系统分析、实时监控等领域有广泛的应用。 华为云分布式消息服务Kafka版是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。使用华为云分布式消息服务Kafka版，资源按需申请，即买即用，您将有更多精力
实例管理 新增Kafka实例指定Topic分区 父主题： API V2
Manager Smart Connect管理 分布式消息服务Kafka版通过开启Smart Connect，实现Kafka实例和其他云服务（如OBS）之间的数据同步，或者两个Kafka实例之间的数据同步。 支持区域： 全部 如何开启Smart Connect？ 用户管理 分布式消息服务
图解Kafka、RabbitMQ和RocketMQ的差异
主题管理 Kafka生产消息 Kafka实例创建Topic Kafka实例查询Topic 修改Kafka实例Topic Kafka实例批量删除Topic 查询Topic的分区列表 查询Topic的当前生产者列表 查询Kafka实例Topic详细信息 父主题： API V2（推荐）
Java Java客户端接入示例 Java开发环境搭建
版本公告 版本支持公告 版本发布说明
API V2 生命周期管理 实例管理 消费组管理 Smart Connect 其他接口 父主题： 历史API
管理Kafka Manager 访问Kafka Manager 重置Kafka Manager密码 重启Kafka Manager 关闭Kafka Manager 父主题： 管理实例
如何调用API 构造请求 认证鉴权 返回结果
API V1 实例管理类接口 实例使用类接口 其他接口 父主题： 历史API
消费组管理 重置消费组消费进度到指定位置 查询所有消费组 父主题： API V2
实例规格变更问题 Kafka扩容/缩容会影响业务吗？ 扩容过程中涉及数据迁移吗？ 扩容/缩容过程中生产消息失败 扩容失败提示资源不足
管理消费组 创建Kafka消费组 查看Kafka消费组信息 查看Kafka消费者信息 查看和重置Kafka消费进度 查看Kafka重平衡日志 修改Kafka消费组信息 导出Kafka消费组列表 删除Kafka消费组
消费组问题 Kafka实例是否需要创建消费组、生产者和消费者？ 如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？ 为什么删除消费组不生效？ 实例消费正常，为什么看不到消费者？ Kafka可以删除消费组下不用的Topic吗？
管理消息 查看Kafka消息 修改Kafka消息老化时间 删除Kafka消息 诊断Kafka消息积压
变更计费模式 变更计费模式概述 按需转包年/包月 包年/包月转按需
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
