检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
说明： 在添加订阅后，对应的订阅终端会收到订阅通知，用户要选择确认订阅，后续才能收到告警信息。 通知周期 保持默认，即如果触发告警，每天发送告警通知。 生效时间 告警规则仅在生效时间内发送通知消息，保持默认。 通知内容模板 选择“默认”。
如果目标集群为华为云Kafka实例的话，在分布式消息服务Kafka版控制台的“消费组管理 > 消费进度”中，查看消费进度。
父主题： 实例管理类接口
父主题： 实例管理类接口
Kafka实例完全兼容开源客户端，按照Kafka官网提供的连接说明，与Kafka实例对接。
父主题： 实例管理类接口
= "" obsDestinationDescriptorbody := &model.ObsDestinationDescriptor{ Topics: "topic-test", ConsumerStrategy: model.GetObsDestinationDescriptorConsumerStrategyEnum
Java开发环境搭建 基于收集连接信息的介绍，假设您已经获取了实例连接相关的信息，以及配置好客户端的网络环境。本章节以生产与发送消息的Demo为例，介绍Kafka客户端的环境配置。
租户配置安全组的入方向、出方向规则限制，可以控制连接实例的网络范围，避免DMS for Kafka暴露给不可信第三方，详情请参见配置安全组。安全组入方向规则的“源地址”应避免设置为0.0.0.0/0。
*; import com.huaweicloud.sdk.kafka.v2.model.*; public class CreateConnectorSolution { public static void main(String[] args) {
Build()) request := &model.UpdateSinkTaskQuotaRequest{} request.Body = &model.UpdateSinkTaskQuotaReq{ SinkMaxTasks: int32(9), } response
您需支付按需资源在宽限期内产生的费用，相关费用可在“管理控制台 > 费用中心 ＞ 总览”的“欠费金额”查看，华为云将在您充值时自动扣取欠费金额。在宽限期内删除的按需Kafka实例不会进入回收站，会被彻底删除。
SASL的Kafka实例 04:57 连接未开启SASL的Kafka实例 分布式消息服务Kafka版 介绍怎样连接开启SASL_SSL的Kafka实例 06:16 连接开启SASL_SSL的Kafka实例 分布式消息服务Kafka版 介绍怎样扩容Kafka实例 04:46 变更实例规格
" redisTypeSinkTask:= "standalone" redisPasswordSinkTask:= "********" sinkTaskbody := &model.SmartConnectTaskReqSinkConfig{ RedisAddress
一键式部署，免去集群搭建烦恼 您只需要在实例管理界面选好规格配置，提交订单。后台将自动创建部署完成一整套Kafka实例。 兼容开源，业务零改动迁移上云 兼容社区版Kafka的API，具备原生Kafka的所有消息处理特性。
*; import com.huaweicloud.sdk.kafka.v2.model.*; public class ShowMaintainWindowsSolution { public static void main(String[] args) {
*; import com.huaweicloud.sdk.kafka.v2.model.*; public class DeleteSinkTaskSolution { public static void main(String[] args) {
*; import com.huaweicloud.sdk.kafka.v2.model.*; public class DeleteConnectorTaskSolution { public static void main(String[] args) {
*; import com.huaweicloud.sdk.kafka.v2.model.*; public class PauseConnectorTaskSolution { public static void main(String[] args) {
*; import com.huaweicloud.sdk.kafka.v2.model.*; public class ResumeConnectorTaskSolution { public static void main(String[] args) {
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
