object AdminClientTopicService { def createAdminClient(commandConfig: Properties, bootstrapServer: Option[String]): Admin = { bootstrapServer match { case Some(serverList) => comma... future = new KafkaFutureImpl<>(); future.completeExceptionally(new InvalidTopicException("The given topic name '" + newTopic.name() + "' cannot be represented in a request.")); t...
extends Serializable { /*** @return The name of writer operation.*/String getWriterName(); /*** Configure writer with user defined options.** @param commonConfiguration Common option... > createCommitter() { return Optional.empty(); } /*** @return A serializer which convert committable object to byte array.*/default BinarySerializer getCommittableSerializer() { re...
[] getTypeInfos(); String[] getFieldNames(); int getIndexOfSubtask(); void sendSplitRequest(); }}````### 构造方法这里需要完成和数据源访问各种配置的提取,比如数据库库名表名、消息... throw BitSailException.asBitSailException(RocketMQErrorCode.CONSUMER_CREATE_FAILED, e); }}````数据库````public void start() { this.connection = connectionHolder.connect(); // Constru...
**Stable Release** | 稳定发行版,最新版为 `Arctic Fox|2020.3.1` || **Release candidate** | 即将发布的下一代版本,可以提前体验新特性和优化,最新版为 `Bunblebee|2021.1.1` || **Cana... { username: \"$username\", token: \"$token\"}"; Executors.newSingleThreadExecutor().execute(() -> { Result result; try { result = makeLoginRequest(jsonBody); ...
{ "name":"name", "value":"zhangsan"}Request-example: bash curl -X PUT -H 'Content-Type: application/json; charset=utf-8' -H 'Authorization: ******' -i https://analytics.volcengineapi.com/datap... 插入一个值 REMOVE 在list类型的属性值里删除一个值 4.错误码列表 Error code Error Message Description 备注 400 transmission content is tampered or authorization is invalid 生成的Authorization信息不对 检...
对于 Node.js 函数,veFaaS 使用您提供的index.js文件中定义的 handler 入口函数启动函数服务进程,对请求事件进行处理。示例代码如下: javascript // vefaas-nodejs14-defaultexports.handler = async function han... 参数说明 参数 说明 requestId 系统自动生成的 request uuid,请从 handler 函数里传入的 context 中获取。 返回值函数 handler 的返回值为Object类型,返回值中只有statusCode、headers、body三个键值对最终会返回给...
NotExistJobIds Array of String - URL 批量上传状态查询不存在的 JobId,包括错误的和过期的 JobId。 MediaInfoList参数 类型 示例值 描述 RequestId String RequestId 请求唯一标识,用于日志查询。 JobId String... SpaceName String SpaceName 点播空间名称。 AccountId String AccountId 用户账号的 ID。 SourceInfo Object of SourceInfo - 视频的元信息。 CallbackArgs String xxxxxxxxxxxx 自定义字段,回调时会透传返回。 ...
此接口用于通过源文件 URL,拉取媒体文件并上传到视频点播,支持批量操作。 使用说明提交成功后,将会生成异步执行的任务,进行排队执行。 提交任务后,您可通过以下方式获取 URL 批量拉取上传任务相关信息:通过 QueryU... FileName String 否 example.mp4 文件路径,即文件在点播存储中的存储位置,等同于传统对象存储的对象键(ObjectKey)概念。您可根据业务需求自定义文件路径。最大不超过 1024 个字符。 说明 视频点播中,文件路径...
否则调用 FetchObject 抓取资源会失败。 请求消息样式JSON POST /objectName?fetch HTTP/1.1Host: bucketname.tos-cn-beijing.volces.comDate: GMT DateAuthorization: authorization string { "URL": "http... 服务端会返回 400 InvalidRequest 错误。 x-tos-server-side-encryption-customer-algorithm Header String 否,使用 SSE-C 加密时,必选。 AES256 指定 SSE-C 加密对象要使用的算法,取值说明如下: AES256:使...
你可以使用此接口指定消息 ID 对消息进行批量查询。 使用说明接口行为你可以调用GetMessages接口,指定你所属的AppId和,会话 ID 和消息 ID,查询指定消息的详细信息。 调用接口关于调用接口的服务地址、通信协议、字... CreateTime Long 1669723135771 消息创建时间戳,单位为毫秒 Sender Long 000010 消息发送人 UserId AppId Integer 000000 应用的唯一标志 RefMsgInfo Object of RefMsgInfo - 引用消息 IndexInConversation Long ...
使用限制使用 CopyObject 接口时,Object 的限制说明如下: 目标对象大小范围是 [0, 5GiB],如果源对象大小超过 5GiB,请使用 UploadPartCopy 接口。 使用 CopyObject 或 UploadPartCopy 接口均要求对源 Object 有读权限。 使用 CopyObject 接口拷贝归档存储、冷归档存储和深度冷归档存储对象前,需要先恢复对象。 请求消息样式JSON PUT /DestObjectName HTTP/1.1Host: destbucketname.tos-cn-beijing.volces.comDate: Fri, 30 Jul ...
调用 RestoreObject 接口恢复归档存储(ARCHIVE)、冷归档(Cold Archive)和深度冷归档(DEEP_COLD_ARCHIVE)对象。 注意事项归档存储、冷归档和深度冷归档对象无法直接读取,您需要先恢复该对象,才能执行读取操作。恢复... 恢复模式说明如下:标准取回:一般在 12 小时内完成恢复。 批量取回:一般在 48 小时内完成恢复。 深度冷归档目前处于邀测状态,如您需要使用该功能,请联系客户经理。 请求消息样式JSON POST /objectname?restoreHo...
name="key"objectname--9431149156168Content-Disposition: form-data; name="success_action_redirect"success_redirect--9431149156168Content-Disposition: form-data; name="x-tos-meta-uuid"uuid--943114915... /tos/request。 注意 如果该请求包含了安全策略 policy 参数时,则必须提供此参数。 x-tos-date String 是,有条件 20220101T000000Z ISO8601 格式的日期值。例如,20130728T000000Z。 与在创建签名密钥时使用的...