-
查询Smart Connector任务详情 - 分布式消息服务Kafka版
(仅源端类型为Kafka时会显示) cluster_name String 对端Kafka实例别名。(仅源端类型为Kafka时会显示) user_name String 对端Kafka用户名。
-
错误码 - 分布式消息服务Kafka版
请联系技术支持 400 DMS.00400128 Invalid public access parameters. 公网访问参数错误。
-
创建消费组 - 分布式消息服务Kafka版
success SDK代码示例 SDK代码示例如下。 Java Python Go 更多 创建一个消费组,消费组名为test。
-
扩容/缩容过程中生产消息失败 - 分布式消息服务Kafka版
在重启过程中,分区Leader会进行切换,此时生产客户端的元数据缓存中保存的分区Leader为旧分区Leader ID,仍然会向旧分区Leader发送消息,导致生产消息失败。 解决方法:在生产客户端配置重试机制。
-
为什么可用区不能选择2个? - 分布式消息服务Kafka版
原因如下: 每个Kafka实例包含3个Zookeeper节点,Zookeeper集群用来管理Kafka实例的配置,如果Zookeeper集群出现问题,Kafka实例将无法正常运行。至少2个Zookeeper节点正常运行,才能保证Zookeeper集群正常运行。
-
批量重启或删除实例 - 分布式消息服务Kafka版
success: 操作成功 failed: 操作失败 instance String 实例ID。 请求示例 批量重启实例。
-
重置用户密码 - 分布式消息服务Kafka版
= "Cxxx3" request.Body = &model.ResetUserPasswrodReq{ NewPassword: &newPasswordResetUserPasswrodReq, } response, err := client.ResetUserPasswrod
-
修改用户参数 - 分布式消息服务Kafka版
{ UserDesc: &userDescUpdateUserReq, UserName: &userNameUpdateUserReq, NewPassword: &newPasswordUpdateUserReq, } response, err := client.UpdateInstanceUser
-
Kafka客户端参数配置建议 - 分布式消息服务Kafka版
buffer.memory 33554432 67108864 producer可以用来缓存数据的内存大小。如果数据产生速度大于向broker发送的速度,producer会阻塞或者抛出异常,以“block.on.buffer.full”来表明。
-
创建实例时为什么无法查看子网和安全组等信息? - 分布式消息服务Kafka版
创建实例时,如果无法查看虚拟私有云、子网、安全组、弹性IP,可能原因是该用户的用户组无Server Administrator和VPC Administrator权限。增加用户组权限的详细步骤,请参考修改用户组权限。 父主题: 实例问题
-
修改Kafka实例Topic分区的副本 - 分布式消息服务Kafka版
其中Array首位为leader副本,所有分区需要有同样数量的副本,副本数不能大于总broker的数量。 响应参数 无 请求示例 修改Topic分区的副本分布位置,分区1的副本分布在broker 1和broker 2,Leader副本在broker 1。
-
创建Kafka实例 - 分布式消息服务Kafka版
参数specification为100MB时,取值300 参数specification为300MB时,取值900 参数specification为600MB时,取值1800 参数specification为1200MB时,取值1800 access_user String 否 当
-
Logstash对接Kafka生产消费消息 - 分布式消息服务Kafka版
/config/output.conf 返回“Successfully started Logstash API endpoint”时,表示启动成功。 图4 启动Logstash 在Logstash中,生产消息,如下图所示。
-
批量删除用户 - 分布式消息服务Kafka版
{ Users: &listUsersbody, Action: &actionBatchDeleteInstanceUsersReq, } response, err := client.BatchDeleteInstanceUsers(request) if err
-
修改Kafka实例Topic - 分布式消息服务Kafka版
new_partition_numbers 否 Integer 分区数。
-
查询用户列表 - 分布式消息服务Kafka版
表3 ShowInstanceUsersEntity 参数 参数类型 描述 user_name String 用户名称。 由英文字符开头,只能由英文字母、数字、中划线、下划线组成,长度为4~64的字符。 user_desc String 用户描述。
-
测试Kafka生产速率和CPU消耗 - 分布式消息服务Kafka版
区域:华北-北京四 项目:华北-北京四 可用区:可用区1 实例名称:kafka-test 企业项目:default 版本:2.7 代理规格:kafka.2u4g.cluster 代理个数:3 存储空间:超高I/O,200GB 容量阈值策略:自动删除 虚拟私有云:选择虚拟私有云 安全组
-
快速连接Kafka并生产消费消息 - 分布式消息服务Kafka版
kafka.2u4g.cluster 代理数量 根据业务需求选择相应的代理数量。 3 单个代理存储空间 根据实际需要选择存储Kafka数据的磁盘类型和总磁盘大小。 实例总存储空间 = 单个代理的存储空间 * 代理数量,Kafka实例创建后,磁盘类型不支持修改。
-
Kafka客户端使用建议 - 分布式消息服务Kafka版
consumer需周期poll,维持和server的心跳,避免心跳超时,导致consumer频繁加入和退出,阻塞消费。 consumer拉取的消息本地缓存应有大小限制,避免OOM(Out of Memory)。
-
调用说明 - 分布式消息服务Kafka版
调用说明 分布式消息服务Kafka版提供了REST(Representational State Transfer)风格API,支持您通过HTTPS请求调用,调用方法请参见如何调用API。 父主题: 使用前必读