检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
号进行财务管理。详细介绍请参见通过关联账号维度查看成本分配。 通过企业项目进行成本分配 在进行成本分配之前，建议开通企业项目并做好企业项目的规划，可以根据企业的组织架构或者业务项目来划分。在购买云资源时选择指定企业项目，新购云资源将按此企业项目进行成本分配。详细介绍请参见通过企业项目维度查看成本分配。
用SDK的难度，推荐使用。 SDK列表 在开始使用之前，请确保您安装的是最新版本的SDK。使用过时的版本可能会导致兼容性问题或无法使用最新功能。您可以在SDK中心查询版本信息。 表1提供了分布式消息服务Kafka版支持的SDK列表，您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。
en路径，以及Maven所需的settings.xml文件。 修改Kafka配置信息。 以生产消息为例，具体修改请参考生产消息配置文件。 在IDEA工具的左下角，打开Terminal窗口，执行mvn test命令体验demo。 图4 IDEA的Terminal窗口位置 生产消息会得到以下回显信息：
什么是分布式消息服务Kafka版 Kafka是一个拥有高吞吐、可持久化、可水平扩展，支持流式数据处理等多种特性的分布式消息流处理中间件，采用分布式消息发布与订阅机制，在日志收集、流式数据传输、在线/离线系统分析、实时监控等领域有广泛的应用。 华为云分布式消息服务Kafka版是一款基于开源社区版Kafka提供
付费再使用，按照订单的购买周期进行结算，因此在购买之前，您必须确保账户余额充足。按需计费是一种后付费模式，即先使用再付费，按照Kafka实例实际使用时长计费。关于两种计费模式的详细介绍请参见分布式消息服务Kafka版计费模式概述。 在购买Kafka实例后，如果发现当前计费模式无法
通过账单查找云服务资源并停止计费 为了确保所有计费资源都能够被找到并删除，您可以在费用账单中获取计费资源的ID，通过这些ID信息找到具体的资源，然后将其一一删除。具体操作如下： 进入“费用中心 > 流水和明细账单”页面。 选择“明细账单”，在如下图所示位置单击鼠标左键，复制资源ID。 图1 复制资源ID
优化消费者轮询（Polling） 方案概述 应用场景 在分布式消息服务Kafka版提供的原生Kafka SDK中，消费者可以自定义拉取消息的时长，如果需要长时间的拉取消息，只需要把poll(long)方法的参数设置合适的值即可。但是这样的长连接可能会对客户端和服务端造成一定的压力
分布式消息服务Kafka版支持在控制台查看Java、Go和Python语言的生产消费消息示例代码，您可以参考示例代码快速完成Kafka客户端的集成，并进行消息的生产和消费。 查看Kafka生产消费示例代码 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
重置消费组消费进度到指定位置 功能介绍 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。停止待重置消费组客户端，然后等待一段时间（即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间，默认为1000
重置消费组消费进度到指定位置 功能介绍 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。停止待重置消费组客户端，然后等待一段时间（即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间，默认为1000
据实际业务需求，在控制台自行修改参数值。 支持区域： 全部 如何修改配置参数？ 标签 标签是Kafka实例的标识，为Kafka实例添加标签，可以方便用户识别和管理拥有的Kafka实例资源。 您可以在创建Kafka实例时添加标签，也可以在Kafka实例创建完成后，在实例的详情页添加标签，您最多可以给实例添加20个标签。
MS for Kafka提供的多种安全能力，提高对DMS for Kafka资源的整体安全防御能力，保护存储在DMS for Kafka内的数据不泄露、不被篡改，以及数据在传输过程中不泄露、不被篡改。 本文从以下几个维度给出建议，您可以评估DMS for Kafka的使用情况，并
查询Kafka集群元数据信息 当前页面API为历史版本API，未来可能停止维护。请使用查询Kafka集群元数据信息。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/cluster 参数说明如下表所示。 表1 参数说明
复”。 在待恢复Kafka实例所在行，单击“恢复”。 在弹出的“恢复实例”对话框中，单击“确定”。 恢复实例大约需要3~10分钟，在“Kafka专享版”页面查看已恢复的实例。 包年/包月的实例从回收站中恢复后，计费模式会变为按需计费。 修改保留天数 登录管理控制台。 在管理控制台
传输。 步骤一：创建终端节点服务 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。
对话框。 单击Kafka实例名称，进入实例详情页面。在“基本信息”页面，在“连接信息 > 用户名”后，单击“重置密码”，弹出“重置Kafka密码”对话框。 单击Kafka实例名称，进入实例详情页面。在“用户管理”页面，在待重置密码的用户所在行，单击“重置密码”，弹出“重置密码”对话框。
查看Smart Connect任务 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。
EOM时间 EOS时间 Kafka 1.1.0 在售 2018年5月 暂无计划 暂无计划 2.3.0 EOM 2020年6月 2023年5月5日 2025年9月 2.7 在售 2022年3月 2026年3月 2027年3月 3.x 在售 2024年4月 暂无计划 暂无计划 EOM：End
本次变更如下： 在创建实例的“specification”参数中，增加新规格描述。 在创建实例中，新增“broker_num”参数。 2022-01-26 本次变更如下： 查询产品规格列表V2接口变更为新版本，旧版本接口移入历史API中。 2021-12-14 本次变更如下： 在权限和授
关闭重平衡日志。 开启重平衡日志 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
