检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
担心配置、部署、持续的硬件维护等。此外，DIS还可在云区域同步复制数据，为您提供数据高可用性和数据持久性。 主要模块 DIS分为4个功能模块，各模块功能如下： 服务控制面 完成服务的开通、删除、配置操作，并将用户信息同步到数据面。 完成数据面资源的申请与自动部署。 服务数据面 接
llback，当提交偏移量完成后会自动调用其onComplete()方法，以便根据回调结果执行不同的逻辑处理； commitSync()是同步提交，会阻塞线程直到提交消费偏移量执行结果返回。 另外还可以精细的控制对具体分区具体offset数据的确认，确认的offset为已接受数据
llback，当提交偏移量完成后会自动调用其onComplete()方法，以便根据回调结果执行不同的逻辑处理； commitSync()是同步提交，会阻塞线程直到提交消费偏移量执行结果返回。 另外还可以精细的控制对具体分区具体offset数据的确认，确认的offset为已接受数据
DIS对数据传输所需要的基础设置、存储、网络和配置进行管理。您无需为数据通道担心配置、部署、持续的硬件维护等。此外，DIS还可在云区域同步复制数据，为您提供数据高可用性和数据持久性。 SDK概述 数据接入服务软件开发工具包（DIS SDK，Data Ingestion Service
void commitSync() 接口 支持 同步提交当前消费的offset void commitSync(final Map<TopicPartition, OffsetAndMetadata> offsets) 接口 支持 同步提交指定的offset void commitAsync()
void commitSync() 接口 支持 同步提交当前消费的offset void commitSync(final Map<TopicPartition, OffsetAndMetadata> offsets) 接口 支持 同步提交指定的offset void commitAsync()
} // 数据处理完成之后异步提交当前offset(也可使用同步提交commitSync) consumer.commitAsync(new OffsetCommitCallback()
} // 数据处理完成之后异步提交当前offset(也可使用同步提交commitSync) consumer.commitAsync(new OffsetCommitCallback()
Producer<String, String> producer = new DISKafkaProducer<>(props); // 同步发送 synchronousSendDemo(producer, streamName); // 异步发送
Producer<String, String> producer = new DISKafkaProducer<>(props); // 同步发送 synchronousSendDemo(producer, streamName); // 异步发送
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
