Streams完成单词统计功能，通过读取输入Topic中的消息，统计每条消息中的单词个数，从输出Topic消费数据，将统计结果以Key-Value的形式输出。 创建 MRS 集群 购买一个包含有Kafka组件的MRS集群，详情请参见购买自定义集群。 本文以购买的MRS 3.1.0版本的集群为例，组件包含Hado

查看更多 →

本地读单边写模式应在配置文件中配置routeStrategy为"local-read-single-write"。在这种路由模式下，读操作在本地进行，不受MAS指示的活跃节点影响。根据配置文件中的az信息判断本地属于哪个az，读操作时从本地az进行读取，写操作仍然根据MAS指示的活跃节点进行操

查看更多 →

Kafka应用开发建议 同一个组的消费者的数量建议与待消费的Topic下的Partition数保持一致 若同一个组的消费者数量多于Topic的Partition数时，会有多余的消费者一直无法消费该Topic的消息，若消费者数量少于Topic的Partition数时，并发消费得不到完全体现，因此建议两者相等。

查看更多 →

参数类型 描述 view_id 是 String 参数解释： 标准页面的ID值，可通过调用5.2.8.1-查询标准页面列表接口查看（响应消息中的“id”）。 约束限制： 不涉及。 取值范围： 不涉及。 默认取值： 不涉及。 请求参数 无 响应参数 表2 响应参数 参数 参数类型 描述

查看更多 →

"SERVICECOMB_INSTANCE_PROPS": "cas_lane_tag:gray,affinity-tag:gray","ip":"x.x.x.x" } } 全部流量路由方向为从非基线泳道（gray）的unit-controller实例流向基线泳道（base）的unit-consu

查看更多 →

bigdata.kafka.example.Consumer类中，用于实现使用Consumer API订阅安全Topic，并进行消息消费。 代码样例 /** * Consumer构造函数。 * @param topic 订阅的Topic名称。 */ public

查看更多 →

如上图，实线为DCG指示激活AZ1，虚线为DCG指示激活为AZ2。跟场景三不同之处在于，场景四中存在从库，进行读写分离，写操作在主库，读操作在从库进行。 配置如下： # 基础信息 - 可选项, 当配置etcd后为必选 props: version: v1 // 项目版本号，自定义 appId:

查看更多 →

描述 status String 异步任务的状态：等待中、运行中、已完成、失败 枚举值： waiting running finished failed task_data OptimizationTaskData object 分子优化任务的请求体 result OptimizationResult

查看更多 →

指示激活为AZ2。跟场景一类似，同样在单边进行读写，不同之处在于，场景二中存在从库，进行读写分离，写操作在主库，读操作在从库进行。 配置如下： # 基础信息 - 可选项, 当配置etcd后为必选 props: version: v1 // 项目版本号，自定义 appId:

查看更多 →

MAS服务中连接池中的命名一致。如果不对接MAS服务，props配置、etcd配置无需配置，sources数据源配置本地所用数据库即可。 下列场景中的配置都包含了props、etcd的配置，配置项的具体值含义参考配置项详细信息列表。 Mas-DB-SDK配置示例，这里的配置只作为

查看更多 →

bigdata.kafka.example.Consumer类中，用于实现使用Consumer API订阅安全Topic，并进行消息消费。 代码样例 /** * Consumer构造函数。 * @param topic 订阅的Topic名称。 */ public

查看更多 →

bigdata.kafka.example.Consumer类中，用于实现使用Consumer API订阅安全Topic，并进行消息消费。 代码样例 /** * Consumer构造函数。 * @param topic 订阅的Topic名称。 */ public

查看更多 →

华为云 MapReduce服务 提供了Kafka服务多种场景下的样例开发工程，本章节对应示例场景的开发思路： 使用Kafka客户端创建两个Topic，用于输入Topic和输出Topic。 开发一个Kafka Streams完成单词统计功能，通过读取输入Topic中的消息，统计每条消息中的单词个数，从输出Topic消

查看更多 →

CG指示的active影响。根据配置文件中的az信息判断本地属于哪个az，读操作时从本地az进行读取，写操作仍然根据DCG指示的active进行操作。 本地读单边写策略，配置文件中props.azs信息必须填写，根据实际所属az填写，不同az的服务，配置文件中props.azs信

查看更多 →

String 异步任务的状态：等待中、运行中、已完成、失败 枚举值： waiting running finished failed task_data CpiTaskData object CPI任务的请求体 result CpiResult object CPI任务的返回结果 表4 CpiTaskData

查看更多 →

// 认证用的ak和sk直接写到代码中有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； // 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_

查看更多 →

在常规代码开发中，我们需要为某个区块或者某个元素添加一些事件，比如单击事件，同一个页面的事件会统一保存到对应的页面JS中。 很多时候我们需要自定义一些方法去复用一些逻辑，也需要用到页面JS。 需要注意的是当前的页面JS只能使用声明函数，不能使用函数表达式声明函数，也不能在页面JS中定义其他的变量。

查看更多 →

，只有通过此API注册后的事件才会在组件的事件列表中展现。 thisObj：当前组件实例对象，指为该组件注册事件。 "eventName"：事件名称，应该与触发事件API中的第一个参数保持一致。 "Event Label"：事件标签名，在事件列表中展示的事件标题。 []：定义该事

查看更多 →

组件化开发思想 采用Vue.js的组件化开发思想，将整体功能模块包装成一个个独立且可复用的组件，独立维护自身的状态及样式，更好地隔离多方合作伙伴的不同诉求，提升代码的可维护性。 基于Webpack的构建过程 使用Webpack作为构建工具，通过对源代码进行打包、压缩、合并等操作，最终生成

查看更多 →

bigdata.kafka.example.Consumer类中，用于实现使用Consumer API订阅安全Topic，并进行消息消费。 代码样例 /** * Consumer构造函数。 * @param topic 订阅的Topic名称。 */ public

查看更多 →

支持标准SQL和JDBC API的强大功能，使得SQL用户可以访问HBase集群。 代码样例 以下代码片段在com.huawei.bigdata.hbase.examples包的“PhoenixSample”类的testCreateTable方法中。 /** * Create

查看更多 →