检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
nceByEngineReq, AccessUser: &accessUserCreateInstanceByEngineReq, StorageSpace: int32(300), BrokerNum: int32(3), EngineVersion: "2.7"
图1 华为云安全责任共担模型 云安全责任基于控制权，以可见、可用作为前提。在客户上云的过程中，资产（例如设备、硬件、软件、介质、虚拟机、操作系统、数据等）由客户完全控制向客户与华为云共同控制转变，这也就意味着客户需要承担的责任取决于客户所选取的云服务。如图1所示，客户可以基于自身的
域上线。 内网IP地址 根据实际需求选择“自动分配”或“手动选择”。 自动分配：系统自动分配子网中可用的IP地址。 手动选择：在下拉框中勾选指定的IP地址。如果指定的IP地址数量少于代理数量时，系统会自动为剩余代理分配IP地址。 开启IPv6后，控制台不显示此参数。 安全组 选择已经创建好的安全组。
可能原因3：磁盘容量超过95%，且“容量阈值策略”设置为“自动删除”。 “容量阈值策略”设置为“自动删除”，表示磁盘容量达到95%时，系统会删除最早的10%的消息，以保证磁盘容量充足。当磁盘容量超过95%时，未到达老化时间的消息也会被删除，所以可能会导致部分消息查询不到。 解
描述 topic 是 String Topic名称 brokers 否 Array of integers 分区平衡到的broker列表，自动生成分配方案时需指定该参数。 replication_factor 否 Integer 副本因子，自动生成分配方案时可指定。 assignment
SendKafkaMessageRequestBody(); List<SendKafkaMessageRequestBodyPropertyList> listbodyPropertyList = new ArrayList<>(); listbodyPropertyList
Integer 分区ID。 leader Integer leader副本所在节点的id。 leo long 分区leader副本的LEO（Log End Offset）。 hw long 分区高水位（HW，High Watermark）。 lso long 分区leader副本的LSO（Log
00500006 Internal service error. 内部服务错误。 请联系技术支持。 500 DMS.00500017 Internal service error. 内部服务错误。 请联系技术支持。 500 DMS.00500024 Internal service error.
参数类型 描述 partition Integer 参数解释： 分区ID。 取值范围： 不涉及 leader Integer 参数解释： leader副本所在节点的id。 取值范围： 不涉及 leo Integer 参数解释： 分区leader副本的LEO（Log End Offset）。
connect.converters.ByteArrayConverter"。（仅目标端类型为OBS时会显示） 取值范围： 不涉及。 key_converter String 参数解释： 键转换器，默认为"org.apache.kafka.connect.converters.ByteAr
connect.converters.ByteArrayConverter"。（仅目标端类型为OBS时会显示） 取值范围： 不涉及。 key_converter String 参数解释： 键转换器，默认为"org.apache.kafka.connect.converters.ByteAr
value_converter 否 String 参数解释： 值转换器，默认为"org.apache.kafka.connect.converters.ByteArrayConverter"。（仅目标端类型为OBS时会显示） 取值范围： 不涉及。 key_converter 否 String
是否必选 参数类型 描述 advertised_ip_contents 是 Map<String,String> 用户自定义的advertised_ip_contents键值对。 键是listeners IP。 值是advertised.listeners IP，或者域名。 说明： IP修改未修改项也需填上。
kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); // 开启GZIP压缩
“ssl-user-config.properties”文件，参考3增加用户名和密码，以及SSL证书配置。 在Kafka客户端的“/bin”目录下，通过以下命令查询消费进度。 ./kafka-consumer-groups.sh --bootstrap-server {connection-address}
new_storage_space 否 Integer 扩容后的存储空间。 当oper_type类型是storage或horizontal时，该参数有效且必填。 实例存储空间 = 代理数量 * 每个broker的存储空间。 当oper_type类型是storage时，代理数量不变，每个broker存储空间最少扩容100GB。
&model.KafkaTopicQuota{ ConsumerByteRate: &consumerByteRateKafkaTopicQuota, ProducerByteRate: &producerByteRateKafkaTopicQuota, Topic: &
request_id) print(e.error_code) print(e.error_msg) 修改Topic分区的副本分布位置，分区1的副本分布在broker 1和broker 2，Leader副本在broker 1。 1 2 3 4 5 6
ssl-user-config.properties”文件，参考3增加用户名和密码，以及SSL证书配置。 在Kafka客户端的“/bin”目录下，通过以下命令查询消费组列表。 ./kafka-consumer-groups.sh --bootstrap-server {connection-address}
KMOffsetCache-dms-vm-fa3cf9d6-manager-shared-server-0 for generation 1", "groupId":"KMOffsetCache-dms-vm-fa3cf9d6-manager-shared-server-0", "coordinatorId":"0"
