检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
理,使用时解密。 #SASL认证机制为“PLAIN”时,配置信息如下。 sasl.mechanism=PLAIN sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
product_id 是 String 产品ID。 产品ID可以从查询产品规格列表获取。 maintain_begin 否 String 维护时间窗开始时间,格式为HH:mm。 maintain_end 否 String 维护时间窗结束时间,格式为HH:mm。 enable_publicip
我的配额”。 系统进入“服务配额”页面。 图1 我的配额 您可以在“服务配额”页面,查看各项资源的总配额及使用情况。 如果当前配额不能满足业务要求,请参考后续操作,申请扩大配额。 如何申请扩大配额? 登录管理控制台。 在页面右上角,选择“资源 > 我的配额”。 系统进入“服务配额”页面。
"domain_id": "accountid", "name": "username", "password": "**********", "email": "email", "description":
0、10:00:00、14:00:00和18:00:00。 该参数不能单独为空,若该值为空,则结束时间也为空。系统分配一个默认开始时间02:00:00。 maintain_end String 否 维护时间窗结束时间,格式为HH:mm:ss。 维护时间窗开始和结束时间必须为指定的
messages_remained 分区剩余可消费数,消费组剩余可消费的消息个数 kafka_groups_partitions(kafka消费组维度) messages_consumed 分区已消费消息数,当前消费组已经消费的消息个数 messages_remained 分区剩余可消
描述 private_plain_enable Boolean 实例是否支持内网PLAINTEXT访问接入方式。 true:实例支持内网PLAINTEXT访问方式接入方式。 false:实例不支持内网PLAINTEXT访问接入方式。 private_plain_address String
"rest_produce_failed", "rest_produce_latency", "rest_produce_msg_num", "rest_produce_flow", "rest_consume_success", "rest_consume_failed", "rest_consume_latency"
000000", "domain_id": "d78cbac1..........", "xdomain_id": "30086000........", "xdomain_type": "", "
生产消息失败 问题现象 系统提示“Disk error when trying to access log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间,具体操作请参考变更Kafka实例规格。
默认使用PLAIN机制。 非SASL认证方式 package main import ( "bufio" "fmt" "github.com/confluentinc/confluent-kafka-go/kafka" "log" "os" "os/signal"
Body = &model.UpdateInstanceReq{ MaintainEnd: &maintainEndUpdateInstanceReq, MaintainBegin: &maintainBeginUpdateInstanceReq, Description:
5567", "user_name": "laiyh", "kafka_manager_user": "root", "maintain_begin": "22:00:00", "maintain_end": "02:00:00", "storage_space":
on。 可用区(AZ,Availability Zone) 一个可用区是一个或多个物理数据中心的集合,有独立的风火水电,AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ间通过高速光纤相连,以满足用户跨AZ构建高可用性系统的需求。 项目 区域默认对
ExtendProductPropertiesEntity object 产品规格属性描述。 available_zones Array of strings 有可用资源的可用区列表。 unavailable_zones Array of strings 资源售罄的可用区列表。 表5 E
broker_disk_read_await 磁盘平均读操作耗时 该指标用于统计磁盘在测量周期内平均每个读IO的操作时长。 单位:ms 2020年6月及以后购买的实例,支持此监控项。 >0 Kafka实例节点 1分钟 broker_disk_write_await 磁盘平均写操作耗时 该指
kafka.v2.model.*; public class ShowInstanceTopicDetailSolution { public static void main(String[] args) { // The AK and SK used for
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
参数类型 描述 io_spec String 磁盘IO编码。 type String 磁盘类型。 available_zones Array of strings 可用区。 unavailable_zones Array of strings 不可用区。 表6 ListEngineS