开通消息引擎

Lindorm消息引擎是Lindorm流引擎的底层存储,本文介绍如何开通消息引擎。说明 您可以通过Lindorm管理控制台创建Lindorm实例,购买消息引擎,或为已有的Lindorm实例开通消息引擎。创建实例时开通消息引擎 在 实例列表 中点击 创建。在...

查看消息引擎监控信息

云原生多模数据库 Lindorm 消息引擎提供了三个维度(实例监控、Topic监控和Group监控)的监控,帮助您全方位了解消息引擎的运行状态,使您可以及时调整业务,预防风险。前提条件 已开通消息引擎。如何开通,请参见 开通消息引擎。通过 ...

通过开源Kafka命令行工具访问消息引擎

Lindorm消息引擎完全兼容开源Kafka API,您可以通过开源Kafka命令行工具,实现基础的Topic或Group的信息查看与运维管理。本文介绍如何通过开源Kafka命令行工具访问消息引擎。前提条件 已安装Java环境,要求JDK为1.8及以上版本。已将客户端...

消息引擎与开源Kafka客户端兼容性

本文档介绍消息引擎与开源Kafka客户端兼容性信息,帮助您选择合适的Kafka客户端版本以实现高效且稳定的数据读写操作。兼容 Kafka客户端 版本 消息引擎支持Kafka客户端0.11版本及以上版本的生产或消费接口,您可以根据实际的业务场景选择...

通过开源Kafka客户端写入Lindorm消息引擎数据

Lindorm消息引擎完全兼容开源Kafka API,您可以通过Kafka API编写程序向Lindorm消息引擎写入数据,也可以通过开源的三方工具采集并写入Lindorm消息引擎数据,例如FluentD、Debezium等。本文介绍通过开源Kafka客户端连接Lindorm消息引擎并...

自定义报警配置

当您需要监控 云原生多模数据库 Lindorm 的消息引擎状态时,云原生多模数据库 Lindorm 的消息引擎提供了配置自定义报警,通过配置自定义报警规则,您可以根据不同的业务需求对其状态进行不同维度的监控,以帮助您及时发现异常情况,确保...

引擎简介

云原生多模数据库 Lindorm 消息引擎是Lindorm面向IoT、车联网、日志等流式数据提供的数据接入服务,支持业务原始数据高吞吐写入,并基于流引擎的实时处理能力,业务只需做简单开发,即可快速实现数据的ETL并入库到Lindorm宽表引擎。...

什么是ChatApp 消息服务

ChatApp 消息服务(ChatApp Message Service)是阿里云为全球企业打造的一款高效触达用户的消息引擎,通过与WhatsApp平台合作,使您轻松地使用WhatsApp平台的消息服务,触达全球10亿+用户,通过丰富的消息类型,提升您与客户的互动体验,...

消息转发说明

对于JT/T 808协议云网关设备,设备注册、注销和上报数据的消息,可通过物联网平台规则引擎的云产品流转功能转发到服务端(用户的服务器)。设备上报数据消息可通过规则引擎的AMQP订阅功能推送至服务端。本文介绍通过规则引擎进行消息转发的...

最佳实践概览

ChatApp 消息服务(ChatApp Message Service)是阿里云为全球企业打造的一款高效触达用户的消息引擎,通过与WhatsApp平台合作,使您轻松地使用WhatsApp平台的消息服务,触达全球10亿+用户,通过丰富的消息类型,提升您与客户的互动体验,...

数据指标说明

规则引擎消息流转MQ云产品次数 规则引擎消息流转OTS云产品次数 规则引擎消息流转RDS云产品次数 规则引擎消息流转REPUBLISH云产品次数 规则引擎消息流转TSDB云产品次数 规则引擎消息流转DATAHUB云产品次数 规则引擎消息流转FC云产品次数 ...

智能基线

规则引擎消息流转OTS云产品次数 规则引擎消息流转MQ云产品次数 规则引擎消息流转MNS云产品次数 规则引擎消息流转FC云产品次数 规则引擎消息流转DATAHUB云产品次数 规则引擎流转消息延时 规则引擎消息流转次数 规则引擎流转消息大小

报警信息说明

如示例中,“MessageCountForwardedThroughRuleEngine_MNS”对应类目为“规则引擎消息流转次数(MNS)”,表示在一定时间内,规则引擎流转数据到消息服务(MNS)的次数超过了报警规则中设置的阈值。具体类目名称代码说明,请参见 阈值报警...

配置消息灰度

如果您在使用金丝雀发布、全链路灰度以及开发环境隔离等场景中需要使用到消息的灰度,那么您需要开启消息灰度的功能。目前,MSE只支持RocketMQ类型的消息灰度。背景信息 虽然绝大多数业务场景下对于消息的灰度的要求并不像RPC的要求得这么...

使用云消息队列 Kafka 版时客户端的报错及解决方案

在使用云消息队列 Kafka 版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java ...如果是Local存储引擎消息添加key值。

园区空间数据变更订阅

1、消息订阅 1、获取项目appkey和appSecret 使用阿里云账号登录数字园区引擎,登录后如下图所示 点击对应的园区,则会进入该园区的管理页面,在园区概览菜单下,可以查看园区项目的appKey和appSecret 2、获取实例ID 3、获取数据模型id 在...

开发场景:基于消息队列RocketMQ版实现环境隔离

本文介绍如何在 Serverless应用引擎SAE(Serverless App Engine)上基于阿里云 消息队列RocketMQ版 实现环境隔离,您可以在不修改任何业务代码的情况下,实现异步场景下的流量控制。背景信息 支持RocketMQ版本:4.2.0及以上版本。支持Pull...

GetAppMessageQueueRoute-获取应用消息灰度信息

获取应用消息灰度相关的信息。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息,可以在RAM权限策略语句的 Action ...

部署应用后如何推送消息通知?

本文介绍在使用SAE时,如何为应用设置消息推送。应用部署到SAE后,您可以为应用设置消息推送,获取指定的异常状态报告,例如CPU过载、实例重启等。SAE支持以下两种推送方式。监控告警 这类通知适合具体监控指标异常时的通知。如果是CPU、...

UpdateMessageQueueRoute-更新应用消息灰度的配置

更新应用消息灰度的配置。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息,可以在RAM权限策略语句的 Action 元素中...

SAE可以不停顿地读取Kafka消息吗?

支持。部署在SAE的应用可以读取Kafka消息,如果需要根据消息量扩容/缩容,建议您对接 SAE API,自行编写程序来控制实例数。

园区空间和设备绑定关系变更订阅

1、消息订阅 1、获取项目appkey和appSecret 使用阿里云账号登录数字园区引擎,登录后如下图所示 点击对应的园区,则会进入该园区的管理页面,在园区概览菜单下,可以查看园区项目的appKey和appSecret 2、获取实例ID 3、获取数据模型id 在...

基于消息队列RocketMQ版实现全链路灰度

通过消息队列这类异步场景下的流量控制,您可以在不需要修改任何业务代码的情况下,实现全链路灰度。本文介绍MSE基于消息队列RocketMQ版实现全链路灰度。前提条件 开通MSE微服务治理。创建Kubernetes托管版集群。Demo架构 本文以容器服务...

步骤三:创建资源

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

如何快速测试云消息队列 Kafka 版服务端是否正常?

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Input接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Input接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Output接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Input接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Output接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Output接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Output接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

作为Input接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

将云消息队列 Kafka 版接入阿里云Elasticsearch

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

Kafka数据接入

消息队列 Kafka 版 支持以下两种存储引擎。云存储:底层接入阿里云云盘,具有低时延、高性能、持久性、高可靠等特点,采用分布式3副本机制。实例的 规格类型 为 标准版(高写版)时,存储引擎只能为 云存储。Local 存储:使用原生Kafka的...

功能特性

查看、修改和重启Nacos实例 创建Nacos引擎 创建ZooKeeper引擎 管理MSE ZooKeeper实例 变更实例规格 设置实例参数 对Nacos,ZooKeeper的各类参数进行设置。设置引擎参数 版本升级 对Nacos,ZooKeeper引擎的版本进行升级。升级Nacos引擎版本 ...

基本概念

本文说明 云消息队列 Kafka 版 涉及的专有名词和术语,帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台,可以实时发布、订阅、存储和处理数据流。更多信息,请参见 Apache Kafka。云消息队列 Kafka 版...

为什么Topic有分区时间显示1970或“-”?

问题现象 Topic的分区更新时间显示为1970或者为“-”。可能原因 出现此问题的原因可能...如果是Local存储引擎,您可以使用消息查询功能查看正确消息生产时间。如果是云存储引擎,并且缓存过期,您可以使用消息查询功能查看正确消息生产时间。

定时/延时消息

待消费 定时时刻到达后,服务端将消息重新写入普通存储引擎,对下游消费者可见,等待消费者消费的状态。消费中 消息被消费者获取,并按照消费者本地的业务逻辑进行处理的过程。此时服务端会等待消费者完成消费并提交消费结果,如果一定时间...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
微服务引擎 Serverless 应用引擎 云消息队列 Kafka 版 消息服务 云消息队列 RocketMQ 版 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用