检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消息消费平均处理时长，服务端处理消息消费请求平均时长 kafka_topics（kafka topic维度） topic_data_size 队列数据容量，当前队列的数据容量 topic_messages_in_rate 消息生产速率，每秒钟生产的消息数量 topic_bytes_out_rate
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
安全协议设置为“SASL_SSL”时，采用SASL方式进行认证，数据通过SSL证书进行加密传输，安全性更高。此时需要配置连接实例的用户名和密码，以及证书文件。 安全协议设置为“SASL_PLAINTEXT”时，采用SASL方式进行认证，数据通过明文传输，性能更好。此时需要配置连接实例的用户名和密码，无需配置证书文件。
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
PLAINTEXT：表示客户端访问Kafka实例时，无需认证，数据通过明文传输。 SASL_SSL：表示客户端访问Kafka实例时，使用SASL认证，数据通过SSL证书加密传输。 SASL_PLAINTEXT：表示客户端访问Kafka实例时，使用SASL认证，数据通过明文传输。 步骤一：创建终端节点服务
通过以下任意一种方法，导出用户列表。 勾选待导出的用户，单击“导出 > 导出已选中数据到XLSX”，导出指定用户列表。 单击“导出 > 导出全部数据到XLSX”，导出全部用户列表。 请注意：初始用户无法被选中，如果要导出初始用户，请使用“导出全部数据到XLSX”。 父主题： 配置Kafka访问控制
policiesOnly Boolean 是否为默认策略。 id String Topic名称 replication Integer 副本数，配置数据的可靠性 partition Integer Topic分区数，设置消费的并发数。 retention_time Integer 消息老化时间。
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
安全协议设置为“SASL_SSL”时，采用SASL方式进行认证，数据通过SSL证书进行加密传输，安全性更高。此时需要配置连接实例的用户名和密码，以及证书文件。 安全协议设置为“SASL_PLAINTEXT”时，采用SASL方式进行认证，数据通过明文传输，性能更好。此时需要配置连接实例的用户名和密码，无需配置证书文件。
资源状态变为“已冻结”，您将无法对处于保留期的按需计费资源执行任何操作。 保留期到期后，若您仍未支付账户欠款，那么Kafka实例将被释放，数据无法恢复。释放的实例会被彻底删除，不会进入回收站。 图1 按需计费Kafka实例生命周期 华为云根据客户等级定义了不同客户的宽限期和保留期时长。
最新动态（html） 本文介绍了Huawei Cloud EulerOS产品新特性和对应的文档动态，新特性将在各个区域（Region）陆续发布，欢迎体验。
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
设置消息删除参数，如表1所示。 图1 消息删除 表1 消息删除参数说明 参数 说明 分区 选择消息所在的分区编号。 偏移量 输入偏移量，最早偏移量到输入偏移量之前的数据将被删除。例如：最早偏移量为2，输入的偏移量为5，此时会删除偏移量为2到4的消息。 请注意以下几点： 如果“偏移量”设置为“-1”，表示删除分区中所有的消息。
仅在“消费组状态”为“EMPTY”时，支持删除。 消费组包含以下状态： DEAD：消费组内没有任何成员，且没有任何元数据。 EMPTY：消费组内没有任何成员，存在元数据。 PREPARING_REBALANCE：准备开启Rebalance。 COMPLETING_REBALANCE：所有成员加入消费组。
重置密码 重置Manager密码 重启Manager 开启或关闭实例自动创建Topic功能 修改实例跨VPC访问的内网IP 查询Kafka集群元数据信息 查询Kafka实例的协调器信息 修改Kafka实例Topic分区的副本 修改Kafka的接入方式 查询Topic的磁盘存储情况 Kafka实例开始分区重平衡任务
下划线开头，且只能英文字母、 数字、句点、中划线、下划线组成，长度3~64个字符。 消费组名称开头包含特殊字符，例如#号“#”，会导致监控数据无法展示。 描述 消费组的描述信息，长度0~200个字符。 在消费组列表页面，查看新创建的消费组。 父主题： 管理消费组
2019-12-10 新增以下接口： 查询分区指定偏移量的消息 查询分区指定时间段的消息 查询分区最新消息的位置 查询分区最早消息的位置 查询Kafka集群元数据信息 查询消费组信息 重置消费组消费进度到指定位置 查询实例在CES的监控层级关系 查询Kafka实例所有消费组对应的协调器信息 新增Kafka实例指定Topic分区
unclean.leader.election.enable 指示是否启用不在ISR集合中的副本选为领导者作为最后的手段，即使这样做可能导致数据丢失。 true/false false connections.max.idle.ms 此参数用来指定在多少毫秒之后，关闭空闲的连接。 5000
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
