检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
earch:8.7.1 restart: always container_name: elasticsearch # 如果ElasticSearch占用资源过高,导致容器无法成功启动,可取消此处的代码注释,根据服务器情况对资源使用进行限制 # deploy:
> Java Class”,在“Name”中输入“Main”单击“OK”,完成“Main”文件创建。 图14 新建Class 配置Class。 创建完成后,打开“Main”文件,添加“public static void main(String[] args)”。 图15 设置Class的配置
than the number of available brokers. 创建Topic的副本数大于当前可用的Broker数。 请检查Topic的副本数。 400 MQS.00500963 Failed to delete assets. 删除资产失败。 请联系技术支持升级MQS实例版本。
检查请求是否合法。 500 APIC.0605 Backend domain name resolution failed. 检查域名拼写,以及域名是否绑定了正确的后端地址。 500 APIC.0606 Failed to load the API configurations.
检查请求是否合法。 500 APIC.0605 Backend domain name resolution failed. 检查域名拼写,以及域名是否绑定了正确的后端地址。 500 APIC.0606 Failed to load the API configurations.
如果需要使用自定义认证方式进行API的安全认证,请提前创建前端自定义认证。 限制与约束 如果为自定义后端发布的前端API的请求路径增加了请求参数,那么无法在自定义后端的发布页面进行发布,需要在前端API页面进行发布操作。如果只修改了自定义后端的内容,建议重新部署即可,无需重新发布。 操作步骤
导致消息堆积的常见原因如下: 生产者短时间内生产大量消息到Topic,消费者无法及时消费。 消费者的消费能力不足(消费者并发低、消息处理时间长),导致消费效率低于生产效率。 消费者异常(如消费者故障、消费者网络异常等)导致无法消费消息。 Topic分区设置不合理,或新增分区无消费者消费。 Topic频繁重平衡导致消费效率降低。
能,降低您使用SDK的难度,推荐使用。 SDK列表 在开始使用之前,请确保您安装的是最新版本的SDK。使用过时的版本可能会导致兼容性问题或无法使用最新功能。您可以在SDK中心查询版本信息。 表1提供了ROMA Connect服务支持的SDK列表,您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。
如果需要使用自定义认证方式进行API的安全认证,请提前创建前端自定义认证。 限制与约束 如果为自定义后端发布的前端API的请求路径增加了请求参数,那么无法在自定义后端的发布页面进行发布,需要在前端API页面进行发布操作。如果只修改了自定义后端的内容,建议重新部署即可,无需重新发布。 操作步骤
OMA Connect可靠存储。 消息消费 消息消费时,消费者需要确认消息是否已被成功消费。 生产的消息被依次存储在ROMA Connect的存储介质中。消费时依次获取ROMA Connect中存储的消息。消费者获取消息后,进行消费并记录消费成功或失败的状态,并将消费状态提交到ROMA
在“服务列表”中选择应用与数据集成平台,进入ROMA Connect主界面,单击右上角“购买ROMA Connect实例”,尝试购买ROMA Connect实例,如果无法购买ROMA Connect实例(假设当前权限仅包含ROMA ReadOnlyAccess),表示“ROMA ReadOnlyAccess”已生效。
规则,对日志数据进行拆分和过滤,然后将解析后的日志数据发送到ELK的ElasticSearch进行存储。 ELK的ElasticSearch接收到日志数据后,生成日志数据的索引并存储数据,为Kibana的可视化显示提供聚合搜索和数据分析的支撑。 用户使用ELK的Kibana创建日
修改实例维护时间窗 instance updateRomaInstanceMaintainTime 修改实例的弹性公网ip instance updateRomaInstanceEip 清除创建失败的实例 instance cleanFailedRomaInstance CTS支持的ROMA FDI操作
CreateSuccess:创建成功 CreateFail:创建失败 Initing:初始化中 Registering:注册中 Running:运行中 InitingFailed:初始化失败 RegisterFailed:注册失败 Installing:安装中 InstallFailed:安装失败 Updating:升级中
SESSION TO c##xstrm CONTAINER=ALL; GRANT SET CONTAINER TO c##xstrm CONTAINER=ALL; GRANT SELECT ON V_$DATABASE to c##xstrm CONTAINER=ALL; GRANT FLASHBACK
200 表3 响应Body参数 参数 参数类型 描述 failed_groups Array of FailedGroupsEntity objects 删除失败的消费组列表。 total Integer 删除失败的个数。 表4 FailedGroupsEntity 参数 参数类型 描述
通常在调用API的鉴权过程中,您需要用到账号、用户和密码等信息。 区域(Region) 从地理位置和网络时延维度划分,同一个Region内共享弹性计算、块存储、对象存储、VPC网络、弹性公网IP、镜像等公共服务。Region分为通用Region和专属Region,通用Region指面向公共租户提供通用
fka所有消息数据迁移到ROMA Connect实例。 若原Kafka的Topic为单副本存储,ROMA Connect实例中的Topic为3副本存储,则建议ROMA Connect实例存储空间为原Kafka的3倍。 父主题: 消息集成指导
中的数据: id city uuid1 suzhou uuid2 shanghai 数据映射输出数据为: ManufacturerId, ProductName uuid1, suzhou uuid2, shanghai 场景2:目的端数据源选择数据格式“CSV”,是否跳过标题:false,字段分隔符:逗号。
务器。生产者将数据发布到Kafka集群,消费者从Kafka集群订阅数据并进行处理,代理服务器则是Kafka集群中的核心组件,负责处理消息的存储和转发。Kafka的主要优点是可扩展性、高吞吐量、低延迟、可靠性和持久性。它被广泛应用于大数据处理、实时数据流处理、日志收集等领域。 创建Kafka连接