检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
X.X.X目录下是所有依赖的jar包，如果使用非Maven工程，则可导入此lib目录下的所有jar到环境依赖即可 huaweicloud-dis-kafka-adapter-X.X.X-demo是一个样例工程，使用maven编写 例如使用IntelliJ IDEA，可按如下方式导入工程。
dic。 使用DIS SDK创建APP，需要指定APP名称。 1 2 // APP名称 String appName = "myApp"; 配置APP名称之后，通过调用createApp的方法创建APP。 dic.createApp(myApp); 父主题： 使用SDK（Java）
删除通道 参考初始化DIS客户端的操作初始化一个DIS客户端实例，实例名称为dic。 使用DIS SDK删除指定的DIS通道。 1 2 3 4 //待删除的通道名称 String streamName = "myStream"; DeleteStreamRequest deleteStreamRequest
更新转储任务 参考初始化DIS客户端的操作初始化一个DIS客户端实例，实例名称为dic。 使用DIS SDK更新转储任务，需要指定通道名称、转储任务名称，转储周期，转储目标服务等信息。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
订阅所有匹配通配符的通道并支持ConsumerRebalanceListener回调 void unsubscribe() 接口 支持 取消所有订阅 ConsumerRecords<K, V> poll(long var1) 接口 支持 获取消息，但消息当中未实现 checksum(消息的CRC32校验值)、seri
创建通道 参考初始化DIS客户端的操作初始化一个DIS客户端实例，实例名称为dic。 使用DIS SDK创建DIS通道，需要指定通道名称、通道的分片数量以及通道类型。 其中，普通通道为“STREAM_TYPE_COMMON”，高级通道为“STREAM_TYPE_ADVANCED”。
源创建DStream对接SparkStreaming。 DIS Spark Streaming使用流程如图1所示。 图1 DIS Spark Streaming使用流程 父主题： 使用DIS Spark Streaming下载数据
在Linux服务器上停止DIS Agent 使用PuTTY工具登录日志所在服务器。 进入DIS Agent安装目录。 cd /opt/dis-agent-X.X.X/ 停止DIS Agent。 bash bin/stop-dis-agent.sh 请确保使用bash执行脚本，否则使用sh、./ 等方式启
配置好以上参数，执行createApp_sample.py文件调用createApp_test方法，响应201表示创建成功。 父主题： 使用SDK（Python）
配置好以上参数后，执行delete_dump_task_sample.py文件默认调用delete_dump_task_test方法，获取响应204删除成功。 父主题： 使用SDK（Python）
'app_id': 'OPKQuggQVtfqhyvK0cs', 'create_time': 1532425956631} 父主题： 使用SDK（Python）
配置好以上参数，执行commitCheckpoint_sample.py文件调用commitCheckpoint_test方法，响应201表示成功。 父主题： 使用SDK（Python）
"sequence_number_range": "[0 : 10]", "partition_id": "shardId-0000000000"}]} 父主题： 使用SDK（Python）
已从Eclipse官网下载并安装Eclipse IDE for Java Developers最新版本。 已在Eclipse中配置好JDK。 父主题： 使用SDK（Java）
'shardId-0000000001', 'last_transfer_timestamp': 1538018072564}]} 父主题： 使用SDK（Python）
配置好参数后，执行createstream_sample.py文件默认调用createStream_test方法，获取响应201创建成功。 父主题： 使用SDK（Python）
bin/start-dis-agent.sh -c config/anotherAgent.yml -n anotherAgent 请确保使用bash执行脚本，否则使用sh、./ 等方式启动脚本，可能由于系统默认shell的差异导致启动失败。 显示类似如下信息，表示Agent启动成功。 Success
删除转储任务 参考初始化DIS客户端的操作初始化一个DIS客户端实例，实例名称为dic。 使用DIS SDK删除指定的转储任务。 1 2 3 4 5 6 7 DeleteTransferTaskRequest request = new DeleteTransferTaskRequest();
删除APP 参考初始化DIS客户端的操作初始化一个DIS客户端实例，实例名称为dic。 使用DIS SDK创建DIS通道，需要指定APP名称。 1 2 // 待删除APP名称 String appName = "myApp"; 配置APP名称之后，通过调用deleteApp的方法删除APP。
StringSerializer.class.getName()); // 默认情况下不需要设置endpoint，会自动使用域名访问；如需使用指定的endpoint，解除如下注释并设置endpoint即可 // props.setProperty(DISConfig
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
