分布式消息服务 Kafka 

 

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

 
 

    kafka java sdk 更多内容
  • 截断对象(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)

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序(Java)

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

    来自:帮助中心

    查看更多 →

  • 下载与安装SDK(Java SDK)

    下载与安装SDK(Java SDK) 下载SDK OBS Java SDK最新版本源码:最新版本源码下载 OBS Java SDK历史版本下载地址:历史版本下载 如需采用Maven依赖方式获取SDK,请参见安装SDK章节。 安装方式概览 如表1所示,Java SDK以下安装方式。

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序(Java)

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

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序(Java)

    Flink Kafka样例程序(Java) 功能介绍 在Flink应用中,调用flink-connector-kafka模块的接口,生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序(Java)

    Flink Kafka样例程序(Java) 功能介绍 在Flink应用中,调用flink-connector-kafka模块的接口,生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink

    来自:帮助中心

    查看更多 →

  • SDK公共响应头(Java SDK)

    SDK公共响应头(Java SDK) 调用ObsClient类的相关接口成功后,均会返回公共响应头类,即HeaderResponse类实例(或其子类实例),该类包含了HTTP/HTTPS的响应头信息。 处理公共响应头的示例代码如下: 1 2 3 4 5 6 7 8

    来自:帮助中心

    查看更多 →

  • SDK自定义异常(Java SDK)

    SDK自定义异常(Java SDK) SDK自定义异常(ObsException)是由ObsClient统一抛出的异常,继承自java.lang.RuntimeException类。通常是OBS服务端错误,包含OBS错误码、错误信息等,便于用户定位问题,并做出适当的处理。 Obs

    来自:帮助中心

    查看更多 →

  • 使用前准备(Java SDK)

    使用前准备(Java SDK) 在使用Java SDK访问对象存储服务OBS之前,您需要先完成服务环境的准备和开发环境的准备。服务环境准备包括准备账号和访问密钥,是使用SDK与OBS云服务交互的必要条件。开发环境准备是指为了您能顺利完成SDK的安装、完成基于SDK的代码开发与运行

    来自:帮助中心

    查看更多 →

  • 初始化(Java SDK)

    初始化(Java SDK) 初始化概述(Java SDK) 创建并配置客户端(Java SDK) 配置SDK日志(Java SDK)

    来自:帮助中心

    查看更多 →

  • 设置桶配额(Java SDK)

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

    来自:帮助中心

    查看更多 →

  • 上传对象(Java SDK)

    上传对象(Java SDK) 对象上传简介(Java SDK) 流式上传(Java SDK) 文件上传(Java SDK) 获取上传进度(Java SDK) 创建文件夹(Java SDK) 设置对象元数据(Java SDK) 分段上传(Java SDK) 设置对象生命周期(Java

    来自:帮助中心

    查看更多 →

  • 对象上传简介(Java SDK)

    对象上传简介(Java SDK) 开发过程中,您有任何问题可以在github上提交issue,或者在华为云对象存储服务论坛中发帖求助。 在OBS中,用户操作的基本数据单元是对象。OBS Java SDK提供了丰富的对象上传接口,可以通过以下方式上传对象: 流式上传 文件上传 分段上传

    来自:帮助中心

    查看更多 →

  • 分段上传(Java SDK)

    分段上传(Java SDK) 分段上传概述(Java SDK) 初始化分段上传任务(Java SDK) 上传段(Java SDK) 合并段(Java SDK) 分段上传场景化示例(Java SDK) 取消分段上传任务(Java SDK) 列举已上传的段(Java SDK) 列举分段上传任务(Java

    来自:帮助中心

    查看更多 →

  • 追加上传(Java SDK)

    参数解释: 服务端加密头信息。详见SseCHeader。 约束限制: 服务端加密SSE-C方式,那么追加上传和初始化段一样,设置诸如x-obs-server-side-encryption之类的请求Header,后续追加上传也必须携带。 默认取值: 无 input java.io.InputStream

    来自:帮助中心

    查看更多 →

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