发送，实现同步发送。 java.util.concurrent.Future<RecordMetadata> send(ProducerRecord<K,V> record, Callback callback) 带回调函数的发送接口，通常用于异步发送后，通过回调函数实现对发送结果的处理。

查看更多 →

通过VPN实现专线加密 方案概述 组网和资源规划 配置DC 配置VPN 结果验证 父主题： 站点入云VPN企业版

查看更多 →

于iOS平台。 Android上的表现就具有比较大的随机性，由于碎片化严重，各个版本和机型的系统浏览器实现都有差异。 综上所述，APP端使用HTTP-FLV播放协议能更好地实现秒开。

查看更多 →

使用kafka-consumer-groups.sh查看当前消费情况。 查看Offset保存在Kafka上的Consumer Group列表： ./kafka-consumer-groups.sh --list --bootstrap-server <Broker的任意一个节点的业务IP:Kafka集群IP端口号>

查看更多 →

发送，实现同步发送。 java.util.concurrent.Future<RecordMetadata> send(ProducerRecord<K,V> record, Callback callback) 带回调函数的发送接口，通常用于异步发送后，通过回调函数实现对发送结果的处理。

查看更多 →

当encode为user_defined时，需配置该参数，指定用户自实现编码类的类名（包含完整包路径），该类需继承类DeserializationSchema。 encode_class_parameter 否 当encode为user_defined时，可以通过配置该参数指定用户自实现编码类的入参，仅支持一个string类型的参数。

查看更多 →

当encode为user_defined时，需配置该参数，指定用户自实现解码类的类名（包含完整包路径），该类需继承类DeserializationSchema。 encode_class_parameter 否 当encode为user_defined时，可以通过配置该参数指定用户自实现解码类的入参，仅支持一个string类型的参数。

查看更多 →

使用kafka-consumer-groups.sh查看当前消费情况。 查看Offset保存在Kafka上的Consumer Group列表： ./kafka-consumer-groups.sh --list --bootstrap-server <Broker的任意一个节点的业务IP:Kafka集群IP端口号>

查看更多 →

调用API实现人脸检测 本章节提供了通过Postman调用FRS服务人脸检测API（V2）的样例，帮助您零编码快速体验并熟悉FRS服务的使用方法。 使用FRS服务API的详细步骤如下所示： 步骤1：开通服务 步骤2：配置环境 步骤3：Token认证鉴权 步骤4：调用服务 准备工作

查看更多 →

SparkRTC如何实现云端录制？ 具体操作步骤请参见云端录制管理。 父主题： 录制相关

查看更多 →

如何实现横屏视频通话？ 调用setLayoutDirect接口，设置显示模式“layoutDirect”为0，表示设置为横屏模式。 父主题： SDK使用

查看更多 →

OBS如何实现备份和容灾？ OBS通过如下方式实现备份和容灾： 创建桶时开启多AZ属性，用户数据冗余存储至多个AZ中。 通过跨区复制功能。用户可以将一个区域的桶中数据复制到另一个区域，实现云端备份。 将OBS中的数据下载到本地，本地备份数据。 父主题： 数据安全、迁移和备份

查看更多 →

云连接如何实现高可用？ 云连接Region内云连接为集群部署形态且跨AZ部署多集群。 云连接跨Region使用华为云骨干链路，两个Region之间至少为主备冗余链路。 云连接有专门的拨测平台实时监控云连接集群及链路运行情况。 父主题： 产品咨询

查看更多 →

云连接如何实现高可用？ 云连接Region内云连接为集群部署形态且跨AZ部署多集群。 云连接跨Region使用华为云骨干链路，两个Region之间至少为主备冗余链路。 云连接有专门的拨测平台实时监控云连接集群及链路运行情况。 父主题： 带宽、丢包与延迟问题

查看更多 →

使用MAS实现API异常监控 概述 API监控可实现监控用户业务APIG入口的可用性。配置告警前提下，当APIG异常时，API监控在监测到该异常后会立即发送告警通知给用户。 本章通过完成一个样例帮助您快速熟悉使用API监控实现API异常监控的过程。使用API监控的步骤如下所示： 步骤一：创建MAS应用

查看更多 →

对接SMTP实现邮件发送功能 背景信息 简单邮件传输协议（SimpleMailTransferProtocol，简称SMTP），是一种提供可靠且有效电子邮件传输的协议。在AstroZero中应用通过与SMTP对接，实现邮件发送功能。如何开通邮箱的SMTP功能，请参见服务编排、BPM、脚本中发送邮件功能不可用。

查看更多 →

crt") print('start producer') producer = KafkaProducer(bootstrap_servers=conf['bootstrap_servers'], sasl_mechanism="PLAIN"

查看更多 →

WriteIntoKafka" + " /opt/test.jar --topic topic-test -bootstrap.servers 10.91.8.218:9092"); System.out.println("./bin/flink

查看更多 →

WriteIntoKafka" + " /opt/test.jar --topic topic-test -bootstrap.servers 10.91.8.218:9092"); System.out.println("./bin/flink

查看更多 →

当encode为user_defined时，需配置该参数，指定用户自实现解码类的类名（包含完整包路径），该类需继承类DeserializationSchema。 encode_class_parameter 否 当encode为user_defined时，可以通过配置该参数指定用户自实现解码类的入参，仅支持一个string类型的参数。

查看更多 →

length < 6) { System.err.println("Usage: SecurityKafkaWordCount <bootstrap-servers> " + "<subscribe-type> <topics> <protocol> <service>

查看更多 →