-
测试Kafka生产速率和CPU消耗 - 分布式消息服务Kafka版
throughput:每秒发送的消息数。 测试步骤 测试场景一:批处理大小 登录客户端服务器,进入“kafka_2.12-2.7.2/bin”目录下,执行以下脚本。 batch.size=1KB,执行脚本如下: ./kafka-producer-perf-test.sh --producer-props bootstrap
-
停止计费 - 分布式消息服务Kafka版
删除”,对Kafka实例执行删除操作,确保列表中已无该资源。 按需计费资源删除后,可能还会存在账单信息,因为系统通常会在使用后1个小时内对上一个结算周期的费用进行扣款。例如在8:30删除按小时结算的Kafka实例,但是8:00~9:00期间产生的费用,通常会在10:00左右才进行扣费。
-
查询转储任务列表 - 分布式消息服务Kafka版
tasks 参数 参数类型 描述 task_id String 任务ID。 task_name String 转储任务名称。 destination_type String 转储任务类型。 create_time Long 转储任务创建时间戳。 status String 转储任务状态。
-
包年/包月转按需 - 分布式消息服务Kafka版
到期转按需”。 勾选Kafka实例名称左侧的方框,可选一个或多个,单击信息栏左上侧的“更多 > 到期转按需”,弹出“到期转按需”对话框,单击“是”。 查看资费变更的相关信息,确认无误后单击“到期转按需”。 在费用中心转按需 进入“费用中心 > 续费管理”页面。 自定义查询条件。 可在“
-
使用VPCEP实现跨VPC访问Kafka - 分布式消息服务Kafka版
在“基本信息”页面的“高级配置”区域,获取Kafka实例的网卡地址(listeners IP)和对应的Port ID。 图3 Kafka实例的网卡地址(listeners IP)和对应的Port ID 在“基本信息”页面的“网络”区域,查看Kafka实例所在的VPC名称。 图4 查看Kafka实例所在的VPC名称
-
查询消费组信息 - 分布式消息服务Kafka版
balance。 CompletingRebalance:所有成员加入group。 Stable:消费组内成员可正常消费。 coordinator_id Integer 协调器编号。 members Array of members objects 消费者列表。 group_message_offsets
-
查询Smart Connect任务列表 - 分布式消息服务Kafka版
String 转储启动偏移量,latest为获取最新的数据,earliest为获取最早的数据。(仅目标端类型为OBS时会显示) destination_file_type String 转储文件格式。当前只支持TEXT。(仅目标端类型为OBS时会显示) deliver_time_interval
-
Kafka连接问题排查和解决 - 分布式消息服务Kafka版
已开启sasl_ssl访问的Kafka实例为例,执行如下命令: curl -kv {ip}:{port} 网络正常,如下: 网络异常/不通,如下: 解决方案: 检查是否同一个VPC。如果不是,请参考跨VPC访问。 检查安全组规则是否配置正确。请参考如何选择和配置安全组。 检查Consumer和Producer的配置
-
配置Kafka的SSL双向认证 - 分布式消息服务Kafka版
按照提示信息输入证书拥有者的信息,如姓名、单位、所在城市等。 执行以下命令,创建CA的认证证书。 openssl req -new -x509 -keyout ca-key -out ca-cert -days 3650 按照提示信息输入PEM密码。 按照提示信息输入证书拥有者的信息。 执行以下命令,从1中生成的server
-
购买Kafka实例 - 分布式消息服务Kafka版
子网,请根据实际需要进行配置。 共享VPC是基于资源访问管理(Resource Access Manager,简称RAM)服务的机制,VPC的所有者可以将VPC内的子网共享给一个或者多个账号使用。通过共享VPC功能,可以简化网络配置,帮助您统一配置和运维多个账号下的资源,有助于提
-
修改Kafka消息老化时间 - 分布式消息服务Kafka版
列表页面。 通过以下任意一种方法,修改Topic老化时间。 勾选Topic名称左侧的方框,可选一个或多个,单击信息栏左上侧的“编辑Topic”。 在待修改老化时间的Topic所在行,单击“编辑”。 在“编辑Topic”对话框中,输入老化时间,单击“确定”。 父主题: 管理消息
-
状态码 - 分布式消息服务Kafka版
Partial Content 服务器成功处理了部分GET请求。 300 Multiple Choices 多种选择。请求的资源可包括多个位置,相应可返回一个资源特征与地址的列表用于用户终端(例如:浏览器)选择。 301 Moved Permanently 永久移动,请求的资源已被永久的移动到新的URI,返回信息会包括新的URI。
-
实例升级 - 分布式消息服务Kafka版
请求Body参数 参数 是否必选 参数类型 描述 is_schedule 否 Boolean 是否作为定时任务执行。若非定时执行,则is_schedule 和execute_at字段可为空;若为定时执行,is_schedule为true,execute_at字段非空。 execute_at 否 Long
-
自动续费 - 分布式消息服务Kafka版
费”。 图2 单个资源开通自动续费 批量资源开通自动续费:选择需要开通自动续费的Kafka实例,单击列表左上角的“开通自动续费”。 图3 多个资源开通自动续费 选择续费时长,并根据需要设置自动续费次数,单击“开通”。 在“续费管理”页面开通的自动续费,自动续费周期以实际选择的续费
-
查询Smart Connector任务详情 - 分布式消息服务Kafka版
String 转储启动偏移量,latest为获取最新的数据,earliest为获取最早的数据。(仅目标端类型为OBS时会显示) destination_file_type String 转储文件格式。当前只支持TEXT。(仅目标端类型为OBS时会显示) deliver_time_interval
-
删除Kafka Topic - 分布式消息服务Kafka版
在左侧导航栏选择“Topic管理”,进入Topic列表页面。 通过以下任意一种方法,删除Topic。 勾选Topic名称左侧的方框,可选一个或多个,单击信息栏左上侧的“删除Topic”。 在待删除Topic所在行,单击“更多 > 删除”。 在“删除Topic”对话框中,单击“确定”,确认删除Topic。 删除Kafka
-
快速连接Kafka并生产消费消息 - 分布式消息服务Kafka版
xxx.xxx.xxx:9093,192.xxx.xxx.xxx:9093”为Kafka实例连接地址。 执行完命令后,输入需要生产的消息内容,按“Enter”发送消息到Kafka实例,输入的每一行内容都将作为一条消息发送到Kafka实例。 [root@ecs-kafka bin]#./
-
修改Kafka Topic分区数 - 分布式消息服务Kafka版
c列表页面。 通过以下任意一种方法,修改Topic分区数。 勾选Topic名称左侧的方框,可选一个或多个,单击信息栏左上侧的“编辑Topic”。 在待修改分区数的Topic所在行,单击“编辑”。 在“编辑Topic”对话框中,输入分区数,单击“确定”。 分区数只支持增加,不支持减少。
-
Kafka实例开始分区重平衡任务 - 分布式消息服务Kafka版
否 Integer 重平衡门限值。 is_schedule 否 Boolean 是否作为定时任务执行。若非定时执行,则is_schedule 和execute_at字段可为空;若为定时执行,is_schedule为true,execute_at字段非空。 execute_at 否 Long
-
设置Kafka Topic权限 - 分布式消息服务Kafka版
能订阅/发布此Topic。“allow.everyone.if.no.acl.found”在配置参数中修改。 如果Topic已授权某一个或多个用户,此时只有授权的用户可以订阅/发布此Topic,其他未授权的用户不能订阅/发布此Topic。 如果Topic同时设置了“默认用户”权限和单个用户权限,取两者的并集。