replication-factor 一定要在1和32767之间。 if (topic.replicationFactor.exists(rf => rf > Short.MaxValue || rf < 1)) throw new IllegalArgumentException(s"The replication factor must be... null) throw e if (!(e.getCause.isInstanceOf[TopicExistsException] && topic.ifTopicDoesntExist())) throw e.getCause } } ...}```- 判断副本数、分区...
public Receive createReceive() { return receiveBuilder() .matchEquals("worker", e -> log.info("i get a message test{}", e)) .matc... ActorRef.noSender()); // 中断worker // worker.tell(PoisonPill.getInstance(), ActorRef.noSender()); ActorSelection actorSelection = acto...
(mObject,referenceQueue);Log.e("Test","弱引用 "+weak.get());Constant.INSTANCE.hold(mObject);mObject = null;System.gc();Thread.sleep(2000);Log.e("Test","弱引用 "+weak.get());Log.e("Test","弱引... return trackOOM()}```### 2.2.1 trackOOM方法分析在call方法中,其实做的一个核心任务就是trackOOM,我们看下这个方法中主要是干了什么```kotlinprivate fun trackOOM(): LoopState { SystemInfo.refre...
getSplitCoordinatorCheckpointSerializer() { return new SimpleBinarySerializer<>(); } /** * Create type info converter for the source, default value {@link BitSailTypeInfoConverter} */... target.type: int - source.type: float64 target.type: double - source.type: string target.type: string - source.type: date target.type: date.date - source.type: null t...
Read:只读。 Write:只写。 ReadWrite:读写。 Operator String 可选 Remove 添加或者删除 ACL 配置。 Set:添加 ACL 权限配置。 Remove:删除 ACL 权限配置。 说明 CreateTopic 接口中无需设置此参数。 ModifyTopicAuthorities 接口中,此参数必选。 BasicChargeInfo实例的计费信息。被以下接口引用。 DescribeInstanceDetail 参数 参数类型 示例值 说明 ChargeType String PrePaid 实例的计费类型。 PostPaid:按量计...
"message":"success"} 属性值操作接口:单个属性Path: /dataprofile/openapi/v1/{app_id}/items/{item_name}/{item_id}/attributes/{attribute}Method: PUTContent-Type: application/json; charset=utf-8R... return signKeyInfo + "/" + signResult; } private static String sha256Hmac(String message, String secret) { String hash = ""; try { Mac sha256_HMAC = Mac.getInstance("H...
"message":"success"} 属性值操作接口:单个属性Path: /dataprofile/openapi/v1/{app_id}/items/{item_name}/{item_id}/attributes/{attribute}Method: PUTContent-Type: application/json; charset=utf-8R... return signKeyInfo + "/" + signResult; } private static String sha256Hmac(String message, String secret) { String hash = ""; try { Mac sha256_HMAC = Mac.getInstance("H...
("yourAPPID", "yourCHANNEL");// 设置私有化部署数据上送地址,参考2.2节获取,例如 https://yourdomain.com,注意域名后不要加“/”config.setUriConfig(UriConfig.createByDomain("yourREPORT_URL", null));// 是否... 关联多个埋点应用(多个 appid),共用增长营销套件 SDK 时; JavaJava /* 多实例初始化SDK 实例1*/final InitConfig config1 = new InitConfig("yourAPPID1", "yourCHANNEL1");// 创建实例IAppLogInstance appLogInst...
("yourAPPID", "yourCHANNEL");// 设置私有化部署数据上送地址,参考2.2节获取,例如 https://yourdomain.com,注意域名后不要加“/”config.setUriConfig(UriConfig.createByDomain("yourREPORT_URL", null));// 是否... 关联多个埋点应用(多个 appid),共用增长营销套件 SDK 时; JavaJava /* 多实例初始化SDK 实例1*/final InitConfig config1 = new InitConfig("yourAPPID1", "yourCHANNEL1");// 创建实例IAppLogInstance appLogInst...
返回参数参数 类型 示例值 描述 InstanceInfo Object of ESInstanceInfoDTO 实例配置详情信息。 ESInstanceInfoDTO参数 类型 示例值 描述 ESEip String 180.*.*.* 实例所绑定的 EIP。 Status String Running ... false:不会主动延长会话有效期。此种配置下可以实现会话超时过期效果,当登录时长达到 Session 有效时长后,将会自动退出登录。 TagInfo参数 类型 示例值 描述 Type String CUSTOM 节点标签的类型。 CUSTOM:自定...
Body参数 类型 是否必选 示例值 描述 InstanceId String 否 o-0080**iu98 需要查询节点信息的实例 ID。 返回参数参数 类型 示例值 描述 Nodes Array of ESNodeInfo 实例节点列表,以及节点类型、运行状态、资源配... DisplayName String 2核4GiB 节点规格的显示名称。 请求示例json POST https://open.volcengineapi.com/?Action=DescribeInstanceNodes&Version=2023-01-01Content-Type: application/jsonX-Date: 20231003T10402...
("yourAPPID", "yourCHANNEL");// 设置私有化部署数据上送地址,参考2.2节获取,例如 https://yourdomain.com,注意域名后不要加“/”config.setUriConfig(UriConfig.createByDomain("yourREPORT_URL", null));// 是否... 关联多个埋点应用(多个 appid),共用增长营销套件 SDK 时; JavaJava /* 多实例初始化SDK 实例1*/final InitConfig config1 = new InitConfig("yourAPPID1", "yourCHANNEL1");// 创建实例IAppLogInstance appLogInst...
InstanceId String 是 kafka-cnngbnntswg1****x 需要重置消费位点的实例 ID。 GroupId String 是 my_group 需要重置消费位点的消费组 ID。 ResetOffsetsInfo Array of ResetOffsetInfoObject 是 / 需... 详细信息请参考数据结构中的 ResetOffsetInfoObject 部分。 响应参数无 示例 请求示例JSON POST /?Action=ResetConsumedOffsets&Version=2022-05-01 HTTP/1.1Content-Type: application/jsonHost: kafka.volceng...