通过以下任意一种方法，重置初始用户的密码。 在需要重置密码的Kafka实例右侧，单击“更多 > 重置Kafka密码”，弹出“重置Kafka密码”对话框。 单击Kafka实例名称，进入实例详情页面。单击右上角的“更多 > 重置Kafka密码”，弹出“重置Kafka密码”对话框。 单击Kafka实例名称，进入实例详情页面。在“基本信息”页面，在“连接信息

查看更多 →

重启Kafka实例 操作场景 分布式消息服务Kafka版管理控制台支持重启运行中的Kafka实例，且可实现批量重启Kafka实例。 在Kafka实例重启过程中，客户端的生产与消费消息等请求会被拒绝。 前提条件 只有当Kafka实例处于“运行中”或“故障”状态，才能执行重启操作。 重启Kafka实例

查看更多 →

Kafka Consumer API使用样例 功能介绍 下面代码片段在com.huawei.bigdata.kafka.example.Consumer类中，用于消费订阅的Topic消息。 代码样例 Consumer线程的dowork方法逻辑，该方法是run方法的重写 /**

查看更多 →

Kafka 多线程Consumer API 使用样例 功能介绍 在Kafka Consumer API使用样例基础上，实现了多线程并发消费，可根据Topic的Partition数目起相应个数的Consumer线程来对应消费消息。 下面代码片段在com.huawei.bigdata

查看更多 →

支持以下两种配置类型： Kafka地址：输入Kafka实例的信息。 实例名称：选择已创建的Kafka实例。 实例名称 “配置类型”为“实例名称”时，需要设置。 在下拉列表中，选择已创建的Kafka实例。 对端Kafka实例必须和当前Kafka实例处于相同的VPC下，否则无法识别。 Kafka地址

查看更多 →

最新动态（html） 本文介绍了Huawei Cloud EulerOS产品新特性和对应的文档动态，新特性将在各个区域（Region）陆续发布，欢迎体验。

查看更多 →

执行以下命令，切换到客户端目录，例如“/opt/client/Kafka/kafka/bin”。 cd /opt/client/Kafka/kafka/bin 执行以下命令，配置环境变量。 source /opt/client/bigdata_env 启用Kerberos认证的

查看更多 →

下载Kafka命令行工具1.1.0版本或者Kafka命令行工具2.3.0版本或者Kafka命令行工具2.7.2版本或者Kafka命令行工具3.4.0版本，确保Kafka实例版本与命令行工具版本相同。 使用命令行工具连接Kafka实例，具体步骤请参考使用客户端连接Kafka（明文

查看更多 →

None 操作指导 分布式消息服务Kafka版 介绍怎样购买Kafka实例 05:25 购买Kafka实例 分布式消息服务Kafka版 介绍怎样连接Kafka实例 04:57 连接未开启SASL的Kafka实例 分布式消息服务Kafka版 介绍怎样扩容Kafka实例 04:46 变更实例规格

查看更多 →

R/W Kafka消息的时间戳。 timestamp-type STRING NOT NULL R Kafka消息的时间戳类型： NoTimestampType：消息中没有定义时间戳。 CreateTime：消息产生的时间。 LogAppendTime：消息被添加到Kafka Broker的时间。

查看更多 →

R/W Kafka消息的时间戳。 timestamp-type STRING NOT NULL R Kafka消息的时间戳类型： NoTimestampType：消息中没有定义时间戳。 CreateTime：消息产生的时间。 LogAppendTime：消息被添加到Kafka Broker的时间。

查看更多 →

执行以下命令，切换到客户端目录，例如“/opt/client/Kafka/kafka/bin”。 cd /opt/client/Kafka/kafka/bin 执行以下命令，配置环境变量。 source /opt/client/bigdata_env 启用Kerberos认证的

查看更多 →

file_path = "/opt/client/Flink/flink/insertData2kafka.sql" # file_path = os.getcwd() + "/../../../../yarnship/insertData2kafka.sql" # file_path

查看更多 →

支持 含义与kafka设置相同，但默认值为50(kafka是0)，目的是提高Rest接口的上传效率 batch.size 参数 支持 含义与kafka设置相同，但默认值为1MB(kafka是16KB)，目的是匹配流控的大小 buffer.memory 参数 支持 同kafka的默认设置(32MB)

查看更多 →

Kafka样例程序开发思路 场景说明 Kafka是一个分布式消息系统，在此系统上用户可以做一些消息的发布和订阅操作，假定用户要开发一个Producer，让其每秒向Kafka集群某Topic发送一条消息，另外还需要实现一个Consumer，订阅该Topic，实时消费该类消息。 开发思路

查看更多 →

Kafka样例程序开发思路 场景说明 Kafka是一个分布式消息系统，在此系统上您可以做一些消息的发布和订阅操作，假定用户要开发一个Producer，让其每秒向Kafka集群某Topic发送一条消息，另外还需要实现一个Consumer，订阅该Topic，实时消费该类消息。 开发思路

查看更多 →

删除Kafka实例 操作场景 对于按需计费的Kafka实例，控制台支持删除单个实例，也可批量删除实例。对于包年/包月的Kafka实例，如果不再使用，单击“操作”栏下的“更多 > 退订”，退订成功后，Kafka实例会自动被删除。 Kafka实例删除后，实例中原有的数据将被删除，且没有备份，请谨慎操作。

查看更多 →

Hadoop类型： MRS ：表示连接MRS的Kafka。 Apache Kafka：表示连接Apache Kafka的Kafka。 linkConfig.brokerList 是 String Apache Kafka 连接需配置此参数。Kafka broker列表，格式如：“host1:port1

查看更多 →

使用Kafka Kafka用户权限管理 Kafka客户端使用实践 快速使用Kafka生产消费数据 创建Kafka Topic 在Kafka Topic中接入消息 管理Kafka Topic Kafka企业级能力增强 Kafka性能调优 Kafka运维管理 Kafka常见问题

查看更多 →

客户端对象（Client） 本章节介绍了Web SDK的Client接口详情。 序号 接口 描述 1 join 加入房间。调用该接口让用户加入指定房间，进行音频/视频通话。 2 leave 离开房间。用户结束通话后须调用该接口离开房间。 3 publish 加入房间后，发布本地流。

查看更多 →

通过Transport Client接入集群 本文介绍通过Transport Client访问 CSS 服务非安全集群的配置说明。如果是安全模式的集群，建议通过Rest High Level Client访问Elasticsearch集群。 注意事项 建议Transport Client的版本和E

查看更多 →