分布式消息服务 Kafka 

 

分布式消息服务 Kafka 是一个高吞吐、高可用的消息中间件服务,适用于构建实时数据管道、流式数据处理、第三方解耦、流量削峰去谷等场景,具有大规模、高可靠、高并发访问、可扩展且完全托管的特点,是分布式应用上云必不可少的重要组件

 
 

    kafka java sdk 更多内容
  • 使用SDK(Java)

    使用SDKJava) 准备环境 配置样例工程 初始化DIS客户端 创建通道 添加转储任务 更新转储任务 删除转储任务 查询转储列表 查询转储详情 删除通道 查询通道列表 查询通道详情 下载流式数据 上传流式数据 获取数据游标 创建APP 删除APP 新增Checkpoint 查询Checkpoint

    来自:帮助中心

    查看更多 →

  • 使用SDK(Java)

    使用SDKJavaJava开发环境配置 SDK获取和安装 SDK调用示例

    来自:帮助中心

    查看更多 →

  • Kafka Java API接口介绍

    Kafka Java API接口介绍 Kafka相关接口同开源社区保持一致。 Kafka Java API接口介绍可直接参考开源社区。 详情请参见http://kafka.apache.org/documentation.html#api。 父主题: Kafka接口介绍

    来自:帮助中心

    查看更多 →

  • 配置SDK日志(Java SDK)

    配置SDK日志(Java SDK) OBS Java SDK基于Apache Log4j2开源库提供了日志功能,SDK默认会将WARN级别的日志记录到JDK系统变量user.dir所代表的路径下,您可以通过修改日志配置文件定制日志功能。 操作步骤 找到OBS Java SDK开发包中的log4j2

    来自:帮助中心

    查看更多 →

  • Kafka Java API接口介绍

    service.name 服务名。 Kafka集群运行,所使用的Kerberos用户名(需配置为kafka)。 key.serializer 消息Key值序列化类。 指定消息Key值序列化方式。 value.serializer 消息序列化类。 指定所发送消息的序列化方式。 表2 Producer重要接口函数

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序(Java)

    Flink Kafka样例程序(Java) 功能介绍 在Flink应用中,调用flink-connector-kafka模块的接口,生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka,则需要引入 FusionInsight kafka-clients-*.ja

    来自:帮助中心

    查看更多 →

  • Java SDK环境配置

    Java SDK环境配置 Java开发环境配置 SDK的获取与安装 初始化 DLI 客户端 父主题: Java SDK

    来自:帮助中心

    查看更多 →

  • Java SDK使用指导

    40-rc版本后),重定向SDK依赖的第三方库版本,解决版本冲突问题。详情请访问SDK开发中心,查看视频直播Java SDK的“整个SDK Bundle包”内容。 注意:bundle包已经包含了core包和云服务集合包,不需要再单独引入core包和服务包。否则根据maven依赖的

    来自:帮助中心

    查看更多 →

  • Java SDK使用范例

    Java SDK使用范例 以同步执行函数为例,提供封装后的SDK。为了保证您成功使用以下示例代码,您需要先添加对应语言的SDK依赖。 表1 Java SDK信息说明 SDK信息 说明 安装 <dependency> <groupId>com.huaweicloud.sdk</groupId>

    来自:帮助中心

    查看更多 →

  • 快速入门(Java SDK)

    快速入门(Java SDK) 本节介绍在完成SDK的下载和安装后,如何快速上手使用OBS的基础功能,完成创建桶、上传下载对象、列举对象和删除对象。 入门准备 使用SDK管理OBS资源,您需要先完成以下几项准备工作: 使用前须知(Java SDK):了解并选择合适的SDK版本。 使用前准备(Java

    来自:帮助中心

    查看更多 →

  • 管理桶(Java SDK)

    管理桶(Java SDK) 创建桶(Java SDK) 列举桶(Java SDK) 删除桶(Java SDK) 判断桶是否存在(Java SDK) 获取桶元数据(Java SDK) 设置桶ACL(Java SDK) 获取桶ACL(Java SDK) 设置桶策略(Java SDK) 获取桶策略(Java

    来自:帮助中心

    查看更多 →

  • 创建桶(Java SDK)

    创建桶(Java SDK) 功能说明 OBS桶是对象的容器,您上传的文件都将以对象的形式存放在桶中。本文介绍如何使用Java SDK创建桶。 调用创建桶接口,将在当前账号按照用户指定的桶名创建一个新桶,接口支持根据用户诉求,在创建桶的同时配置桶的存储类别、区域及桶的访问权限等参数。

    来自:帮助中心

    查看更多 →

  • 删除桶(Java SDK)

    responseHeaders Map<String, Object> 参数解释: HTTP响应消息头列表,由多个元组构成。元组中String代表响应消息头的名称,Object代表响应消息头的值。 默认取值: 无 代码示例 本示例用于删除桶名为exampleBucket的桶。 1

    来自:帮助中心

    查看更多 →

  • 截断对象(Java SDK)

    截断对象(Java SDK) 功能说明 截断对象操作是指将指定并行文件系统内的一个对象截断到指定大小。 开发过程中,您有任何问题可以在github上提交issue,或者在华为云对象存储服务论坛中发帖求助。 接口约束 您必须是并行文件系统拥有者或拥有截断对象的权限,才能截断对象。建

    来自:帮助中心

    查看更多 →

  • 上传段(Java SDK)

    adPartRequest.setAttachMd5为true来让SDK自动计算每段数据的MD5值(仅在数据源为本地文件时有效),并放到Content-MD5请求头中。OBS服务端会计算上传数据的MD5值与SDK计算的MD5值比较,保证数据完整性。 约束限制: attachMd5

    来自:帮助中心

    查看更多 →

  • 下载对象(Java SDK)

    下载对象(Java SDK) 对象下载简介(Java SDK) 流式下载(Java SDK) 范围下载(Java SDK) 获取下载进度(Java SDK) 限定条件下载(Java SDK) 重写响应头(Java SDK) 获取自定义元数据(Java SDK) 恢复归档或深度归档存储对象(Java

    来自:帮助中心

    查看更多 →

  • 管理对象(Java SDK)

    管理对象(Java SDK) 设置对象元数据(Java SDK) 获取对象元数据(Java SDK) 设置对象ACL(Java SDK) 获取对象ACL(Java SDK) 列举对象(Java SDK) 删除对象(Java SDK) 批量删除对象(Java SDK) 复制对象(Java

    来自:帮助中心

    查看更多 →

  • 删除对象(Java SDK)

    删除对象(Java SDK) 功能说明 为节省空间和成本,您可以根据需要删除指定桶中的对象。 开发过程中,您有任何问题可以在github上提交issue,或者在华为云对象存储服务论坛中发帖求助。 接口约束 您必须是桶拥有者或拥有删除对象的权限,才能删除对象。建议使用IAM或桶策略

    来自:帮助中心

    查看更多 →

  • 日志简介(Java SDK)

    日志简介(Java SDK) 开发过程中,您有任何问题可以在github上提交issue,或者在华为云对象存储服务论坛中发帖求助。 OBS允许您对桶设置访问日志记录,设置之后对于桶的访问会被记录成日志,日志存储在OBS上您指定的目标桶中。 更多关于访问日志的内容请参考日志记录。 父主题:

    来自:帮助中心

    查看更多 →

  • 异常处理(Java SDK)

    异常处理(Java SDK) HTTP状态码(Java SDK) OBS服务端错误码(Java SDK) SDK自定义异常(Java SDK) SDK公共响应头(Java SDK) 日志分析 (Java SDK)

    来自:帮助中心

    查看更多 →

  • 集成ModuleSDK(Java)

    集成ModuleSDK(Java) 内部架构 开发指导 下载demo 集成ModuleSDK进行数据处理 集成ModuleSDK进行工业子系统接入 集成ModuleSDK进行协议转换 集成ModuleSDK进行OT数采 集成ModuleSDK进行进程应用的开发 父主题: 插件侧开发

    来自:帮助中心

    查看更多 →

共105条
看了本文的人还看了