Kafka集群运行，所使用的Kerberos用户名（需配置为kafka）。未开启Kerberos认证的集群无需配置。 Consumer API配置项 表2 consumer.properties文件配置项 参数 描述 备注 security.protocol 安全协议类型 消费者使用的

查看更多 →

费组，如CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_ONSAPI_PERMISSION、CID_ONS-HTTP-PROXY、FILTERSRV_CONSUMER等。这些都是Rocke

查看更多 →

调试尚未发布的API定义 MARKET 调试云商店已购买的API CONSUMER 调试指定运行环境下的API定义 说明： DEVELOPER模式，接口调用者必须是API拥有者。 MARKET模式，接口调用者必须是API购买者或拥有者。 CONSUMER模式，接口调用者必须有API在指定环境上的授权信息或是API拥有者。

查看更多 →

场景描述 本章节指导用户通过API实现微服务注册与发现。API的调用方法请参见如何调用API。 流程介绍 注册第一个微服务my-provider。 注册微服务my-provider的实例。 注册第二个微服务my-consumer。 my-consumer发现第一个微服务my-provider的实例。

查看更多 →

调试尚未发布的API定义 MARKET 调试云商店已购买的API CONSUMER 调试指定运行环境下的API定义 说明： DEVELOPER模式，接口调用者必须是API拥有者。 MARKET模式，接口调用者必须是API购买者或拥有者。 CONSUMER模式，接口调用者必须有API在指定环境上的授权信息或是API拥有者。

查看更多 →

说明 host String 消费组consumer地址。 assignment Array of object assignment consumer分配到的分区信息。参数请参见表5。 member_id String 消费组consumer的ID。 client_id String

查看更多 →

apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:937) at KafkaNew.Consumer$ConsumerThread.run(Consumer.java:40) 可能原因 客户端和服务端Jar版本不一致。

查看更多 →

查询指定消费组信息 功能介绍 查询指定消费组信息。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/mqs/instance

查看更多 →

创建服务间依赖关系 功能介绍 创建服务间的依赖关系，consumer的version必须是确定的版本，consumer的serviceName不能为*，consumer必须是已存在的服务。provider可以是还未创建的。 调用方法 登录ServiceStage控制台，选择“微服务引擎

查看更多 →

反序列化所接收的消息。 表4 Consumer重要接口函数 返回值类型 接口函数 描述 void close() 关闭Consumer接口方法。 void subscribe(java.util.Collection<java.lang.String> topics) Topic订阅接口方法。 ConsumerRecords<K

查看更多 →

auth_time Timestamp 授权时间 auth_role String 授权者： PROVIDER：API提供者授权 CONSUMER：API消费者授权 auth_result String 授权结果： SUCCESS：授权成功 SKIPPED：跳过 响应消息样例： [{ "id":

查看更多 →

调试API 功能介绍 调试一个API在指定运行环境下的定义，接口调用者需要具有操作该API的权限。 URI POST /v1/{project_id}/apic/instances/{instance_id}/apis/debug/{api_id} 表1 路径参数 参数 是否必选

查看更多 →

，对外开放不受语言限制的API (最常用的是HTTP)。多个微服务组成应用程序。 下面介绍如何调用创建微服务静态信息API注册微服务my-provider后，先调用注册微服务实例API注册微服务my-provider的实例，再次调用创建微服务静态信息API注册微服务微服务my-c

查看更多 →

查询指定的数据集分享流程 功能介绍 查询指定的数据集分享流程 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v1/datashare/dataset/query-process

查看更多 →

properties bin/kafka-console-consumer.sh --topic <Topic名称> --bootstrap-server <Kafka集群IP:21009> --consumer.config config/consumer.properties Windows客户端代码使用SSL功能

查看更多 →

使用云日志SDK前，您需要注册华为云账号，并开通云日志服务。 确认云日志服务的区域，请用户根据所在区域，获取regionName。 获取华为账号的AK/SK。 获取华为云账号的项目ID（project id），步骤参考：请参见“我的凭证 > API凭证”。 获取需要上报到LTS的日志组ID、日志流ID、消费组名称。

查看更多 →

查询指定流程创建者的所有流程 功能介绍 查询指定流程创建者的所有流程 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v1/datashare/dataset/query-processes

查看更多 →

反序列化所接收的消息。 表4 Consumer重要接口函数 返回值类型 接口函数 描述 void close() 关闭Consumer接口方法。 void subscribe(java.util.Collection<java.lang.String> topics) Topic订阅接口方法。 ConsumerRecords<K

查看更多 →

afka工程。 导入并配置Kafka样例工程 根据场景开发工程 提供了Producer和Consumer相关API的使用样例，包含了新旧API和多线程的使用场景，帮助用户快速熟悉Kafka接口。 Kafka样例程序开发思路 编译并运行程序 指导用户将开发好的程序编译并打包，上传到VPC的Linux节点运行。

查看更多 →

使用SDK-API消费日志（邀测） 云日志服务LTS 提供SDK-API消费日志接口，用户可以通过调用SDK提供的基础API来消费日志。 目前此功能在邀测中，暂不支持申请开通。 前提条件 使用云日志SDK前，您需要注册华为云账号，并开通云日志服务。 确认云日志服务的区域，请用户根据所在区域，获取regionName。

查看更多 →

反序列化所接收的消息。 表4 Consumer重要接口函数 返回值类型 接口函数 描述 void close() 关闭Consumer接口方法。 void subscribe(java.util.Collection<java.lang.String> topics) Topic订阅接口方法。 ConsumerRecords<K

查看更多 →