-
关闭Smart Connect(按需实例) - 分布式消息服务Kafka版
Connect任务成功。 { "job_id" : "d366178c-29ea-4d5c-a344-fa2ece4a1836" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14
-
购买Kafka实例 - 分布式消息服务Kafka版
开启“Kafka自动创建Topic”表示生产或消费一个未创建的Topic时,系统会自动创建此Topic,此Topic的默认参数值如下: 分区数为3。 副本数为3。 老化时间为72小时。 不开启同步复制和同步落盘。 消息时间戳类型为CreateTime。 批处理消息最大值为10485760字节。
-
Topic是否支持ACL权限配置? - 分布式消息服务Kafka版
SASL_SSL功能,此时Topic支持配置ACL权限。在Kafka控制台的“Topic管理”页面,在需要设置用户权限的Topic所在行,单击“设置用户权限”,为用户设置不同的权限。 具体操作请参考设置Topic权限。 父主题: Topic和分区问题
-
使用客户端连接Kafka(明文接入) - 分布式消息服务Kafka版
103:9094 --topic topic-demo >Hello >DMS >Kafka! >^C[root@ecs-kafka bin]# 如需停止生产使用Ctrl+C命令退出。 执行如下命令消费消息。 ./kafka-console-consumer.sh --bootstrap-server
-
Kafka连接问题排查和解决 - 分布式消息服务Kafka版
检查是否同一个VPC。如果不是,请参考跨VPC访问。 检查安全组规则是否配置正确。请参考如何选择和配置安全组。 检查Consumer和Producer的配置 查看日志,检查Consumer和Producer初始化时打印的参数是否符合预期,是否和自己在配置文件中设置的一致。 如果不一致,请检查配置文件的写法。 Java客户端常见报错
-
状态码 - 分布式消息服务Kafka版
在客户端提供认证信息后,返回该状态码,表明服务端指出客户端所提供的认证信息不正确或非法。 402 Payment Required 保留请求。 403 Forbidden 请求被拒绝访问。 返回该状态码,表明请求能够到达服务端,且服务端能够理解用户请求,但是拒绝做更多的事情,因为该请求被设置为拒绝访问,建议直接修改该请求,不要重试该请求。
-
查询产品规格列表 - 分布式消息服务Kafka版
"cluster", "product_id" : "c6.2u4g.cluster", "ecs_flavor_id" : "c6.large.2", "billing_code" : "dms.platinum.c6", "arch_types" : [ "X86"
-
查询分区最早消息的位置 - 分布式消息服务Kafka版
com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" kafka "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/kafka/v2" "github.com/
-
开启Smart Connect(按需实例) - 分布式消息服务Kafka版
"node_cnt" : 2, "spec_code" : "kafka.c3.mini.connector" } 响应示例 状态码: 200 开启Smart Connect成功。 { "job_id" : "7c3ec20c-11de-4df9-acc0-7ef1dea25dfe",
-
测试Kafka实例TPS - 分布式消息服务Kafka版
否 否 3 30 topic-02 是 否 3 30 topic-03 否 是 3 30 topic-04 否 否 3 3 topic-05 否 否 3 12 topic-06 否 否 3 100 获取测试工具。 获取Kafka命令行工具2.7.2版本。 购买客户端服务器。 购买
-
创建实例 - 分布式消息服务Kafka版
消息存储空间,单位GB。 Kafka实例规格为c6.2u4g.cluster时,存储空间取值范围300GB ~ 300000GB。 Kafka实例规格为c6.4u8g.cluster时,存储空间取值范围300GB ~ 600000GB。 Kafka实例规格为c6.8u16g.cluster时,存储空间取值范围300GB
-
配置Kafka的SSL双向认证 - 分布式消息服务Kafka版
步骤三:开启SSL双向认证 登录管理控制台。 在管理控制台左上角单击,选择区域。 此处请选择与您的应用服务相同的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 单击待开启SSL双向认证的实例名称,进入实例详情页面。 在“连接信息
-
选择和配置安全组 - 分布式消息服务Kafka版
Kafka实例所在安全组需要增加如下规则,以保证能被客户端访问。 表3 安全组规则 方向 策略 协议端口 源地址 入方向 允许 全部 sg-53d4 图2 配置Kafka实例安全组 跨VPC访问和通过DNAT访问实例 请按照表4设置安全组规则。 表4 安全组规则 方向 协议 端口 源地址 说明
-
查询实例的扩容规格列表 - 分布式消息服务Kafka版
[ { "type" : "cluster", "product_id" : "c6.2u4g.cluster", "ecs_flavor_id" : "c3.large.2", "arch_types" : [ "X86" ], "charging_mode"
-
消息超过老化时间,消息仍存在的原因 - 分布式消息服务Kafka版
消息超过老化时间,消息仍存在的原因 问题现象:消息超过设置的老化时间(如果Topic已经设置了老化时间,此时“配置参数”中的log.retention.hours值将不对此Topic生效。仅在Topic中未设置老化时间时,“配置参数”中的log.retention.hours值才会对此Topic生效。),消息仍存在。
-
关闭Smart Connect - 分布式消息服务Kafka版
在管理控制台左上角单击,选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 通过以下任意一种方法,关闭Smart Connect。 在待关闭Smart Connect的Kafka实例所在行,单击“更多
-
开启Smart Connect - 分布式消息服务Kafka版
单击,将Smart Connect设置为开启,单击“下一步”。 确认“Smart Connect”为开启状态,单击“提交”。 后续操作 开启Smart Connect后,您可以配置Kafka间的数据复制、配置Kafka数据转储至OBS,实现分布式消息服务Kafka版和其他云服务之间的数据同步。 父主题:
-
配置消息堆积数监控 - 分布式消息服务Kafka版
过短信/邮件及时收到通知信息,可以参考本章节设置告警通知。 您还可以参考本章节为分布式消息服务Kafka版的其他监控指标设置告警通知。 前提条件 已购买Kafka实例、创建Topic,并且已成功消费消息。 操作步骤 登录分布式消息服务Kafka版控制台,单击待创建告警通知的实例名称,进入实例详情页。
-
使用MirrorMaker跨集群同步数据 - 分布式消息服务Kafka版
测试环境可以为1,生产环境建议以下配置大于1,比如设为3 checkpoints.topic.replication.factor=3 heartbeats.topic.replication.factor=3 offset-syncs.topic.replication.factor=3 # The replication
-
创建Smart Connect任务 - 分布式消息服务Kafka版
"b54c9dd8-********-********", "direction" : "two-way", "sync_consumer_offsets_enabled" : false, "replication_factor" : 3, "task_num"