检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Window”，在新窗口打开此工程。 在新打开的IDEA窗口中，单击“File > Settings”。 在搜索框搜索maven，找到maven的配置，请确保Maven home directory(Maven安装路径)，User settings file (settings.xml文件位置)和Local
ctor-demo目录，单击确认。 选择导入Maven工程，保持默认配置，一直单击下一步即可。 单击“New Window”，在新窗口打开此工程。 在pom.xml上单击右键，选择“Maven > Reimport”，重新引入maven依赖库。 验证Flink Streaming
打开Eclipse。选择“File > Import”弹出“Import”窗口。 选择“Maven > Existing Maven Projects”，单击“Next”，进入“Import Maven Projects”页面。 单击“Browse”按钮，根据实际情况选择“dis-sd
r-X.X.X目录下是所有依赖的jar包，如果使用非Maven工程，则可导入此lib目录下的所有jar到环境依赖即可 huaweicloud-dis-kafka-adapter-X.X.X-demo是一个样例工程，使用maven编写 例如使用IntelliJ IDEA，可按如下方式导入工程。
r-X.X.X目录下是所有依赖的jar包，如果使用非Maven工程，则可导入此lib目录下的所有jar到环境依赖即可 huaweicloud-dis-kafka-adapter-X.X.X-demo是一个样例工程，使用maven编写 例如使用IntelliJ IDEA，可按如下方式导入工程。
打开Eclipse。选择“File > Import”弹出“Import”窗口。 选择“Maven > Existing Maven Projects”，单击“Next”，进入“Import Maven Projects”页面。 单击“Browse”按钮，根据实际情况选择“dis-sd
打开Eclipse。选择“File > Import”弹出“Import”窗口。 选择“Maven > Existing Maven Projects”，单击“Next”，进入“Import Maven Projects”页面。 单击“Browse”按钮，根据实际情况选择“dis-sd
准备DIS Spark Streaming的相关环境 准备DIS应用开发环境 参考步骤1：开通DIS通道准备相应DIS环境。 安装Maven并配置本地仓库地址。 安装scala-sdk。 配置DIS Spark Streaming依赖 项目中可通过以下配置引入DIS Spark Streaming依赖：
准备DIS Flink Connector的相关环境 准备DIS应用开发环境 参考步骤1：开通DIS通道准备相应DIS环境。 安装Maven并配置本地仓库地址。 安装scala-sdk。 配置DIS Flink Connector依赖 项目中可通过以下配置引入DIS Flink Connector依赖：
使用DIS Logstash Plugin上传与下载数据 DIS Logstash Plugin概述 安装DIS Logstash Plugin前准备 在线安装DIS Logstash Plugin 离线安装DIS Logstash Plugin 配置DIS Logstash Plugin
使用Agent上传数据 DIS Agent概述 安装前准备 安装DIS Agent 配置DIS Agent 启动DIS Agent 验证DIS Agent 停止DIS Agent 父主题： 使用DIS
使用DIS Flink Connector上传与下载数据 DIS Flink Connector概述 准备DIS Flink Connector的相关环境 自定义Flink Streaming作业 父主题： 使用DIS
使用Kafka Adapter上传与下载数据 Kafka Adapter概述 准备环境 上传数据 数据下载的消费模式 下载数据之消费位移 与原生KafkaConsumer接口适配说明 父主题： 使用SDK
与原生KafkaConsumer接口适配说明 表1 接口适配说明 原生KafkaConsumer 类型 DISKafkaConsumer 说明 Set<TopicPartition> assignment() 接口 支持 获取consumer消费的通道与分区信息 Set<String>
与原生KafkaConsumer接口适配说明 表1 接口适配说明 原生KafkaConsumer 类型 DISKafkaConsumer 说明 Set<TopicPartition> assignment() 接口 支持 获取consumer消费的通道与分区信息 Set<String>
修订记录 发布日期 修订说明 2019-12-11 第二十四次正式发布： 增加dis-kafka-adapter，增加使用Kafka Adapter上传与下载数据。 2019-10-08 第二十三次正式发布： 优化Java和Python SDK。 2019-07-08 第二十次正式发布：
附录 错误码 状态码 获取项目ID 介绍如何在控制台或者调用API获取项目ID。
图解数据接入服务DIS
监控管理 查询通道监控 查询分区监控 父主题： API说明
异常信息 DIS服务端错误码
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
