正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
标签 添加Topic的发布和订阅消息标签,一般业务场景下无需添加,仅用于特殊业务场景。 添加标签后,客户端向Topic发布和订阅消息时需同时传输标签信息。如果有多个标签,则客户端传输的标签需为Topic包含标签的子集。 配置完成后单击“确定”,完成Topic授权。 父主题: 消息集成指导
Java Demo使用说明 操作场景 除了前面章节介绍的使用原生Kafka客户端,MQS实例还可以通过HTTP RESTful方式访问,包括向指定Topic发送消息、消费消息以及确认消费。 这种方式主要用于适配原有业务系统架构,方便统一使用HTTP协议接入。 入门版规格实例不支持RESTful
0000s。 缓存策略模式 APIC通过客户端请求中的Cache-Control请求头来处理缓存,默认拒绝所有客户端带Cache-Control头的请求。 all:允许所有客户端带Cache-Control头的请求。 off:拒绝所有客户端带Cache-Control头的请求。
Connect实例控制台选择“设备集成 LINK > 设备管理”,在页面中可查看MQTT连接地址/MQTTS连接地址,在“设备”页签的设备列表中,可查看要接入设备的“客户端ID”、“用户名”和“密码”信息。 准备开发环境 安装开发工具 安装2018.3.5或以上版本的IntelliJ IDEA,安装包请至IntelliJ
RY,VARBINARY,IMAGE。 已下载SSMS客户端,下载地址参考SSMS客户端下载。 操作步骤 建议由数据库管理员进行CDC功能的配置操作,以下配置以windows环境为例进行说明。 开启CDC。 使用SSMS客户端连接到SQL Server数据库所在服务器,以sa用户登录数据库。
老化时间(小时) 超过老化时间后,Topic中存储的消息将会被删除。 同步复制 客户端向Topic生产消息时,是否把消息复制给所有副本,然后才向消息客户端返回响应,此处不启用。 同步落盘 消息客户端向Topic生产的每条消息是否立即写入磁盘,此处不启用。 标签 添加Topic的标签信息,用于快速过滤和查找Topic。
properties”、“core-site.xml”,“hdfs-site.xml”,“hosts”和“version”文件。 参考更新客户端配置文件,在MRS控制台下载客户端配置文件,解压后: 从“MRS_Services_ClientConfig_ConfigFiles > MRS_Serv
息被分布式存储在分区中。同一个消费组内,一个消费者可同时消费多个分区,但一个分区在同一时刻只能被一个消费者消费。 在消息处理过程中,如果客户端的消费速度跟不上服务端的发送速度,未处理的消息会越来越多,这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积,从而会造成消息消费延迟。
为什么规则引擎的数据目的端未收到设备发送的消息? 数据目的端未收到设备发送的消息主要有以下原因: 可能是您的安全组没有添加正确的入方向规则。 请您进入“实例信息”界面,找到您的安全组。单击安全组名称进入安全组详情页面,然后根据表1添加相应的入方向规则。 表1 安全组参数 参数 端口
Connect具有相同的数据集成、服务集成和消息集成能力。ROMA Site可部署于用户IDC和第三方公有云,与云端ROMA Connect反向互联,不破坏企业的安全边界。 ROMA Site实例是一个独立的资源空间,所有的操作都是在实例内进行,不同实例间的资源相互隔离。您可以根据业务需要使用一个或多个实例。
TPS(同步复制场景) 分区数上限 存储空间 规格说明 入门版 100MB/s 6万 3万 600 600G Kafka客户端连接数在1500以内,消费组个数在30个以内,业务流量为70MB/s以内时推荐选用。 基础版 100MB/s 10万 6万 600 600G Kafka客户端连接数在3000以
Java:2.7.2及以上版本 Python:2.0.1及以上版本 Go:1.8.2及以上版本 C#:1.5.2及以上版本 客户端开发和配置建议: 请参见客户端使用建议和客户端参数配置建议。 父主题: 开发说明
服务器在完成请求时发生冲突。 返回该状态码,表明客户端尝试创建的资源已经存在,或者由于冲突请求的更新操作不能被完成。 410 Gone 客户端请求的资源已经不存在。 返回该状态码,表明请求的资源已被永久删除。 429 Too Many Request 表明请求超出了客户端访问频率的限制或者服务端接收
消费组名称。长度不超过249位的字符串,包含a~z,A~Z,0~9、中划线(-)和下划线(_)。 ack_wait Integer 否 提交确认消费的超时时间,客户端需要在该时间内提交消费确认,如果超过指定时间,没有确认消费,系统会报消息确认超时或handler无效,则默认为消费失败。取值范围:1~300s。默认值:15s
配置索引生命周期策略(可选) ElasticSearch存储的数据,默认未设置过期时间,用户可根据磁盘空间情况,为ElasticSearch数据设置索引生命周期策略。 创建生命周期策略 登录Kibana可视化界面。 访问地址:IP:Port 其中,IP为ELK所部署服务器的IP;
宽松模式 开启后,当自定义函数服务不可用(与自定义函数服务建立连接失败或者自定义函数服务返回5xx响应)时,ROMA Connect仍然接受客户端请求。 身份来源 添加用于认证的请求参数,支持添加Header参数和Query参数。 当“缓存时间”不为0时,必须添加请求参数。当缓存认证
成应用的Key和Secret。 获取客户端的AppKey和AppSecret: 在ROMA Connect实例控制台选择“服务集成 APIC > API调用”,在“客户端配置”页签中单击API所绑定客户端的名称,进入客户端详情页面,获取客户端的AppKey和AppSecret。 获取认证签名所使用SDK:
控制策略管理 配置流量控制策略 配置访问控制策略 配置客户端配额策略 配置客户端访问控制策略 父主题: 服务集成指导(旧版界面)
开发说明 开发场景 开发规范 客户端使用建议 客户端参数配置建议 父主题: 消息集成开发指导
消息集成(MQS)容量阈值策略 实例中MQS消息存储达到容量阈值时(存储空间的95%)的处理策略,请根据您的业务需要选择。 生产受限:拒绝消息生产请求,直到有消息到达老化时间被删除,腾出存储空间后(剩余存储空间大于5%),才能接收新的消息生产请求。此策略适用于消息消费处理较慢,或者