通过MQTT.fx客户端的Publish功能,发送测试消息,为了测试效果,可以多传输几次。 进入百度消息服务,进入我们使用的主题。 通过百度消息服务BMS的指定主题的监控,可以看到写入指标有增长,说明消息转发并写入成功。
目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 目前只有当主题调整任务设置为自定义执行时间,并且任务没有开始执行才能够取消任务。
前提条件 步骤一:创建Kafka集群 步骤二:创建主题 步骤三:配置权限认证 安装JDK1.8及以上版本: JDK下载地址 。 具体操作步骤 下载Kafka 2.7.2安装包,并进行解压: kafka_2.13-2.7.2.tgz ,其中解压后的bin目录为Kafka提供的可执行脚本。 在 集群详情 中,点击 接入点 查看 SASL_SSL协议 所使用的访问地址和端口。
ID错误 建议联系平台核查原因 移动 M:00121 短消息超过有效期 建议联系平台核查原因 移动 M:00122 短消息的目的地址错误 建议联系平台核查原因 移动 M:00123 短消息的源地址错误 建议联系平台核查原因 移动 M:00124 短消息队列已满 建议联系平台核查原因 移动 M:00125 短消息内容超过了接收侧的最大长度 建议联系平台核查原因 移动 M:00126 短消息中指定的定时时间无效
操作步骤 登录 云监控BCM控制台 ,在左侧的云产品监控中选择 消息服务 for Kafka 产品。 点击集群名称进入监控的详情页面,在这里能够查看监控的基本信息以及报警历史,在 报警策略 中可以查看已经配置的策略信息,并且可以选择不同维度查看策略或者添加策略。 点击 添加策略 按钮进入 创建报警策略 页面,在该页面中配置具体的监控指标以及报警策略。
操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,点击需要操作的集群。 在 任务管理 页面中可以查看集群所产生的任务记录。 点击右侧的 查看 按钮可以进入任务详情页面,在任务详情中可以看到任务的基本信息、任务进度以及本次任务的执行内容。 通过API查看任务详情 您可以通过 查询任务详情 来查询任务详情。
操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,点击需要操作的集群。 在 消费组管理 页面,在需要删除的消费组右侧点击 删除 按钮,确认无误后点击 确定 进行删除。 通过API删除消费组 您可以通过 删除消费组 来删除消费组。
操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,并选择具体的集群。 如果集群当前没有开启SASL/SCRAM身份认证,此时点击左侧的用户管理或者权限管理能够看到访问配置变更的提示页面。 或者在 集群详情 页面中点击 变更 按钮,进入集群变更页面。
用户可以在“开发配置“中设置自己的上行回调地址 HTTP Method POST HTTP Header 头域(Header) 示例值 说明 Content-Type application/json;charset=utf-8 - requestId 54eb30d9-fead-4048-bb8b-200cf12ab8e9 本次推送对应的消息id.客户端可以根据该字段去重 timestamp 1462774903112
规格灵活 可对专享实例节点、带宽与存储资源进行灵活配置组合,自定义集群下主题的分区数、副本数。 弹性扩容 支持对专享实例进行扩容及升配等操作,更好地适应业务规模的增长。 数据安全 利用SASL机制对用户身份进行认证,SSL协议加密的数据传输,保证数据在传输的过程中不被窃听或者篡改,确保客户数据的安全。