ASM默认功能选项参数说明

BOOTSTRAP_XDS_AGENT true false 是否开启Bootstrap启动配置动态生成。accessLogFile/dev/stdout 社区版本相同 accessLog日志输出文件。enablePrometheusMerge true false 如果启用,Istio Agent将合并应用程序公开的指标与EnvoyIstio ...

安装

bootstrap 根据Makefile文件中的规则,逐个编译源代码文件,生成目标可执行文件或库文件。make 安装编译生成的文件。sudo make install 添加环境变量。编辑bash配置文件。vim.bashrc 配置环境变量。CMAKE_PATH=usr/local/cmake export PATH...

通过开源Kafka脚本工具连接Lindorm流引擎

说明 Lindorm流引擎的Lindorm Stream Kafka地址为专有网络地址,需确保应用程序部署的环境Lindorm实例使用相同的专有网络ID。操作步骤 下载开源Kafka脚本工具,下载地址。解压Kafka开源脚本工具。tar-zxf kafka_2.12-2.7.1.tgz cd kafka_...

创建Web函数

如果不配置启动命令,您需要在代码的根目录手动创建一个名称为bootstrap的启动脚本,您的程序通过此脚本来启动。npm run start 监听端口 您的代码中的HTTP Server所监听的端口。9000 高级配置:配置函数的实例相关信息函数执行超时时间等...

默认接入点收发消息

建议您保持服务端客户端版本一致,即保持客户端库版本 云消息队列 Kafka 版 实例的大版本一致。您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面获取 云消息队列 Kafka 版 实例的大版本。准备配置 可选:下载SSL根证书。如果是SSL...

Node.js SDK收发消息

var producer=new Kafka.Producer({/*'debug':'all',*/'api.version.request':'true','bootstrap.servers':config['bootstrap_servers'],'dr_cb':true,'dr_msg_cb':true,'security.protocol':'sasl_ssl','ssl.ca.location':'./ca-cert.pem'...

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

如果您的应用部署在ECS实例,通过专有网络访问Lindorm实例前,需确保Lindorm实例ECS实例满足以下条件,以保证网络的连通性。所在地域相同,并建议所在可用区相同(以减少网络延时)。ECS实例与Lindorm实例属于同一专有网络。操作步骤 以...

建表语句

本文为您介绍Spark SQL建表语法。语法 CREATE TABLE tbName[(columnName dataType[,columnName dataType]*)]...CREATE TABLE kafka_table USING kafka OPTIONS(kafka.bootstrap.servers="${BOOTSTRAP_SERVERS}",subscribe="${TOPIC_NAME}");

使用实例接入点收发消息

Kafka实例提供默认接入点、SSL接入点SASL接入点,以满足您不同的连接安全需求。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;同时需要链路加密消息鉴权,建议使用SSL接入...

使用Kafka(离线与实时)

MaxCompute与Kafka的集成能够提供高效、可靠的数据处理分析能力,适用于需要实时处理、大规模数据流复杂数据分析的场景。本文介绍消息队列Kafka版自建Kafka数据的写入流程,以及自建Kafka数据的写入示例。Kafka数据写入MaxCompute...

快速开始使用EMR Kafka

本文为您介绍如何创建E-MapReduce(简称EMR)Kafka集群、Kafka访问的设置,使用Kafka TopicKafka Connect服务,帮您快速了解上手使用EMR Kafka。创建EMR Kafka集群 该部分内容为您简单介绍如何创建Kafka集群,更详细的创建操作,请参见...

Zookeeper 配置

通过写这两个节点的配置,可以控制相关机器应用的 Biz 运行时状态。配置形式 动态配置采用状态声明指令,SOFAArk 收到配置后,会根据状态描述解析出具体的指令(包括 install、uninstall、switch),指令格式如下:bizName:bizVersion:...

Spark对接Kafka

背景信息 E-MapReduce上的Hadoop集群Kafka集群都是基于纯开源软件,相关编程使用方法可参见官方相应文档。Spark官方文档:streaming-kafka-integration structured-streaming-kafka-integration。E-MapReduce-demo:github地址。访问...

升级或禁止升级云助手Agent

若当前版本的云助手不支持某一功能,您可能需要升级 云助手Agent,本文介绍如何升级禁止升级 云助手Agent。云助手支持的功能与支持该功能的云助手最低版本号,请参见 安装云助手Agent。使用限制 需要升级 云助手Agent 的ECS实例处于 运行...

Upsert Kafka

本文为您介绍如何使用...类别 详情 支持类型 源表结果表 运行模式 流模式 数据格式 avro、avro-confluent、csv、jsonraw 特有监控指标 源表 numRecordsIn numRecordsInPerSecond numBytesIn numBytesInPerScond currentEmitEventTimeLag ...

Confluent Avro

本文为您介绍Confluent Avro格式的使用方法、配置选项类型映射。背景信息 Confluent Avro格式允许读取被io.confluent.kafka.serializers.KafkaAvroSerializer序列化的记录,以及写入能被io.confluent.kafka.serializers....

快速创建函数

使用 函数计算,您无需采购管理服务器等基础设施,只需编写并上传代码或镜像,就可以实现弹性可靠的应用。本文介绍如何在 函数计算 控制台快速开发一个简单的Serverless Hello World函数。前提条件 您已成功注册阿里云账号,并完成实名...

快速使用阿里云RTC Web SDK

获取应用IDAppKey 成功开通应用后,在应用管理列表中找到该应用,点击操作栏中的 管理 按键,进入 基本信息 页面,在该页面下您可以获取到对应的 应用ID AppKey。集成接入 集成SDK Script集成 在您的HTML页面引入SDK脚本。...

常见问题

上传文件报错“Request body is in fail state.Logical error on i/o operation.”错误原因 在上传数据前,C++ SDK会调用iostream的bad()fail()接口检查当前iostream对象实例的状态。如果状态不正确,则提示该错误。解决方法 检查传入的...

接入白板

如果您是由阿里云侧代为采购的,阿里云侧采购后会把对应的AppKeyAppSecret同步给您。开发getAuthInfo接口 请将白板SDK的 appkey、appSecret 添加至您的服务端配置参数中,开发 getAuthInfo 接口,对 appSecret、curTime 等数据做 SHA-1 ...

使用SSL加密Kafka链接

SSL(Secure Sockets Layer)是一种网络协议,提供了一种在客户端服务器之间建立安全连接的方法。启用SSL后,DataFlow集群中的所有数据传输,包括生产者、消费者与Broker之间的消息交互都会被加密,确保敏感信息在网络传输过程中不被窃听...

管理函数

如果不配置启动命令,您需要在代码的根目录手动创建一个名称为bootstrap的启动脚本,您的程序通过此脚本来启动。npm run start 监听端口 说明 仅当您选择 使用自定义运行时创建 函数时,需设置此配置项。您的代码中的HTTP Server所监听的...

PHP SDK收发消息

说明 如果实例未开启ACL,您可以在 云消息队列 Kafka 版 控制台 的 实例详情 页面的 配置信息 区域获取默认的 用户名 密码。如果实例已开启ACL,请确保要使用的SASL用户已被授予向 云消息队列 Kafka 版 实例收发消息的权限。具体操作,...

Canal插件

canal[kə’næl],译意为水道/管道/沟渠,主要用途是基于 MySQL 数据库增量日志解析,提供增量数据订阅消费。早期阿里巴巴因为杭州美国双机房部署,存在跨机房同步的业务需求,实现方式主要是基于业务 trigger 获取增量变更。从 2010 ...

SAP S/4HANA 同可用区高可用部署指南

选择专有网络安全组,需要填写之前创建或者已有的VPC安全组信息(本例以hanasg安全组示意),关于安全组的设置信息请参考 安全组使用FAQ。根据规划需求选择RAM role(可选),检查所有的选项后创建ECS实例,根据本次部署的规划需要...

Kafka数据源

是 kafka.bootstrap.servers Kafka集群连接地址。是 Kafka开启SASL认证 开通SASL权限,具体操作请参见 SASL用户授权。重要 Spark2 Kafka DataSource中不支持设置Kafka的group.id,streaming在消费Kafka数据的时候,每个Streaming作业会自动...

通过Kafka导入数据

云数据库 SelectDB 版 支持通过Doris Kafka连接器(Doris Kafka Connector)自动订阅同步Kafka中的数据。本文介绍Doris Kafka Connector同步数据至 云数据库 SelectDB 版 的使用方式。背景信息 Kafka Connect是一款在Apache Kafka其他...

从Apollo迁移到MSE Nacos

} } 如果您的工程中使用了@ApolloConfig 注解,将其修改为@ConfigurationProperties(prefix="")注解,并且在 bootstrap.properties 中增加相关配置项。在您的业务工程中找到@ApolloConfig 注解,如下所示。Configuration@ApolloConfig ...

快速创建函数

使用 函数计算,您无需采购管理服务器等基础设施,只需编写并上传代码或镜像,就可以实现弹性可靠的应用。本文介绍如何在 函数计算 控制台快速开发一个简单的Serverless Hello World函数。背景信息 通过函数计算控制台快速创建函数的流程...

边缘Agent使用

2.部署Agent Agent可以提供两种运行模式:Java SDK模式独立运行模式。前者是以SDK包的形式包含在应用内,随服务应用一起运行;后者是以独立运行的形式,独立于服务应用运行。2.1 独立运行模式 下载Agent 地址:remote agent 配置启动文件...

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

同时,为了简化配置并保证安全性,消息引擎采用了Bootstrap Server方式,不对外暴露Zookeeper。因此使用开源Kafka客户端进行读写以及DDL操作请使用Bootstrap Server方式。推荐使用2.2.0及以上的客户端版本。具体兼容的Kafka客户端版本如下...

运行日志

设备分发功能的例程运行后,您可以在设备端 物联网平台 查看日志信息。背景信息 已配置C Link SDK的设备分发功能例程,详细信息,请参见 使用示例。设备端日志 您可以在设备端查看运行结果。请求日志:设备向物联网平台发起设备分发请求...

Avro

本文为您介绍Avro格式的使用示例、配置选项类型映射。背景信息 Avro 格式允许基于Avro的结构读写Avro数据。当前,Avro结构是基于表结构推导而来的。支持Avro格式的连接器包括 消息队列Kafka、Upsert Kafka 对象存储OSS。使用示例 利用...

基本概念

自定义组件 在 Quick BI 中,自定义组件(CustomComponent)定义是一个包含了 bootstrap、mount、unmount、update 属性的对象,包含了自定义组件具体的实现的逻辑。详细信息请参考 Lifecycle。举例/这是一个自定义组件 const CustomComponent...

SSL接入点PLAIN机制收发消息

建议您保持服务端客户端版本一致,即保持客户端库版本 云消息队列 Kafka 版 实例的大版本一致。您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面获取 云消息队列 Kafka 版 实例的大版本。准备配置 创建Log4j配置文件 log4j....

将时空数据写入宽表引擎

如果应用部署在ECS,您需要确保 云原生多模数据库 Lindorm 实例ECS实例满足以下条件,以保证网络的连通性。所在地域相同,并建议使用相同的可用区域(以减少网络延时)。使用相同的专有网络。已下载并解压 Lindorm-cli压缩包。准备工作 ...

下载SDK配置

为了保证区块链网络的安全性,BaaS为您托管组织管理员的证书私钥。对于需要管理员权限的操作,请通过BaaS控制台完成,例如上传链码、升级链码、实例化链码、创建通道等。BaaS支持通过社区原生SDK执行 client 权限的操作,例如执行链码、...

EMR Kafka磁盘写满运维

磁盘写满运维概述 本文从磁盘写满监控磁盘写满恢复角度来介绍磁盘写满运维策略。磁盘写满监控 Kafka服务层面:可以在云监控系统中设置EMR Kafka集群的OfflineLogDirectoryCount指标告警,及时发现日志目录offline的情况。磁盘写满恢复 从...

同步数据到时序表

前提条件 已安装Kafka,并且已启动ZooKeeperKafka。更多信息,请参见 Kafka官方文档。已开通表格存储服务,创建实例以及创建时序表。具体操作,请参见 使用流程。说明 您也可以通过Tablestore Sink Connector自动创建目标时序表,此时...

Kafka消费概述

Logstore:日志服务 中日志的采集、存储查询单元。Partition Shard 数据存储分区。Partition:连续的,只增不减。Shard:支持分裂、合并。Offset Cursor Offset:Partition中的消息的顺序ID。Cursor:日志服务 中日志的相对偏移量,通过...
共有8条 < 1 2 3 4 ... 8 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
弹性公网IP 短信服务 人工智能平台 PAI 金融分布式架构 对象存储 物联网平台
新人特惠 爆款特惠 最新活动 免费试用