-
如何查看堆积消息数? - 分布式消息服务Kafka版
在Kafka客户端,在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下,通过kafka-consumer-groups.sh --bootstrap-server {kafka连接地址} --describe --group {消费组}命令查看消费组中每个
-
查看和重置Kafka消费进度 - 分布式消息服务Kafka版
在Kafka客户端的“/bin”目录下,通过以下命令查询消费进度。 .
-
测试Kafka生产速率和CPU消耗 - 分布式消息服务Kafka版
测试步骤 测试场景一:批处理大小 登录客户端服务器,进入“kafka_2.12-2.7.2/bin”目录下,执行以下脚本。 batch.size=1KB,执行脚本如下: .
-
使用MirrorMaker跨集群同步数据 - 分布式消息服务Kafka版
export JAVA_HOME=/opt/java/jdk1.8.0_151 export PATH=$JAVA_HOME/bin:$PATH 执行source .bash_profile命令使修改生效。
-
创建Kafka Topic - 分布式消息服务Kafka版
在Kafka客户端的“/bin”目录下,通过以下命令创建Topic。 .
-
使用前必读 - 分布式消息服务Kafka版
可用区(AZ,Availability Zone) 一个可用区是一个或多个物理数据中心的集合,有独立的风火水电,AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ间通过高速光纤相连,以满足用户跨AZ构建高可用性系统的需求。
-
分布式消息服务Kafka版 - 分布式消息服务Kafka版
产品介绍 什么是Kafka Kafka使用场景 与RabbitMQ、RocketMQ的差异 产品规格 03 入门 创建Kafka实例之后,您可以通过命令行模式和客户端方式连接实例进行生产消息和消费消息。
-
查询指定实例 - 分布式消息服务Kafka版
new_spec_billing_enable Boolean 是否启用新规格计费。 broker_num Integer 节点数量。 tags Array of TagEntity objects 标签列表。 dr_enable Boolean 是否为容灾实例。
-
错误码 - 分布式消息服务Kafka版
400 DMS.00404033 Does not support extend rabbitMQ disk space. 不支持扩容RabbitMQ的磁盘空间。 请使用扩大集群的方式扩容RabbitMQ实例。
-
状态码 - 分布式消息服务Kafka版
403 Forbidden 请求被拒绝访问。 返回该状态码,表明请求能够到达服务端,且服务端能够理解用户请求,但是拒绝做更多的事情,因为该请求被设置为拒绝访问,建议直接修改该请求,不要重试该请求。 404 NotFound 所请求的资源不存在。
-
Logstash对接Kafka生产消费消息 - 分布式消息服务Kafka版
/bin/logstash -f ./config/output.conf 返回“Successfully started Logstash API endpoint”时,表示启动成功。 图4 启动Logstash 在Logstash中,生产消息,如下图所示。
-
查询所有实例列表 - 分布式消息服务Kafka版
new_spec_billing_enable Boolean 是否启用新规格计费。 broker_num Integer 节点数量。 tags Array of TagEntity objects 标签列表。 dr_enable Boolean 是否为容灾实例。
-
构造请求 - 分布式消息服务Kafka版
MIIPAgYJKoZIhvcNAQcCo...ggg1BBIINPXsidG9rZ API同时支持使用AK/SK认证,AK/SK认证是使用SDK对请求进行签名,签名过程会自动往请求中添加Authorization(签名认证信息)和X-Sdk-Date(请求发送的时间)请求头。
-
查询后台任务管理中的指定记录 - 分布式消息服务Kafka版
{ "task_count" : "1", "tasks" : [ { "id" : "8abfa7b272adc5b40172b73130065ae7", "name" : "bindInstancePublicIp", "user_name" :
-
测试Kafka实例TPS - 分布式消息服务Kafka版
export JAVA_HOME=/root/jdk1.8.0_231 export PATH=$JAVA_HOME/bin:$PATH 下载Kafka命令行工具2.7.2版本,并解压。 tar -zxf kafka_2.12-2.7.2.tgz 测试脚本 .
-
查询指定实例 - 分布式消息服务Kafka版
"support_features": "feature.physerver.kafka.topic.accesspolicy,message_trace_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic
-
查询所有实例列表 - 分布式消息服务Kafka版
"support_features": "feature.physerver.kafka.topic.accesspolicy,message_trace_enable,features.pod.token.access,feature.physerver.kafka.pulbic.dynamic
-
创建Kafka实例 - 分布式消息服务Kafka版
true:开启 false:不开启 public_bandwidth String 否 表示公网带宽,单位是Mbit/s。 取值范围: Kafka实例规格为100MB时,公网带宽取值范围3到900,且必须为实例节点个数的倍数。