检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
表2 响应参数说明 参数 类型 说明 messages Array<Object> 消息列表，见表3。 messages_count Long 消息总数。 offsets_count Integer 总页数。 offset Integer 当前页数。
请求参数 无 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 messages Array of messages objects 消息列表。 messages_count Integer 消息总数。
*; public class ShowPartitionEndMessageSolution { public static void main(String[] args) { // The AK and SK used for authentication
请求参数 无 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 messages Array of MessagesEntity objects 消息列表。 total Long 消息总条数。 size Long 每页消息条数。
URI POST /v2/{project_id}/instances/{instance_id}/messages/action 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
*; public class ShowPartitionBeginningMessageSolution { public static void main(String[] args) { // The AK and SK used for authentication
*; public class ShowPartitionMessageSolution { public static void main(String[] args) { // The AK and SK used for authentication
URI DELETE /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/messages 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目
******-9b4a-44c5-a964-************"); body.withPassword("********"); body.withAccessUser("********"); body.withStorageSpace
v\n", ev.TopicPartition) } else { log.Printf("Delivered message to %v\n", ev.TopicPartition) } } } }() // Produce messages
messages：按消息数量排序，默认方式。 sort_dir 否 String 排序方式。 asc：升序。 desc：降序，默认方式。 topic 否 String topic名称。
分区维度） produced_messages 生产消息数，已经生产的消息数 partition_messages 分区消息数，分区当前的消息数 messages_consumed 分区已消费消息数，当前消费组已经消费的消息个数 messages_remained 分区剩余可消费数
*; public class ShowKafkaTopicPartitionDiskusageSolution { public static void main(String[] args) { // The AK and SK used for
"kafka_topics" ], "children" : [ { "name" : "kafka_partitions", "metrics" : [ "produced_messages", "partition_messages" ],
单位：Byte、KB、MB、GB、TB、PB 0~5000000000000 Kafka实例节点 1分钟 broker_messages_in_rate 消息生产速率 该指标用于统计每秒生产的消息数量。
"kafka_topics" ], "children" : [ { "name" : "kafka_partitions", "metrics" : [ "produced_messages", "partition_messages" ],
DMS Hello ^CProcessed a total of 3 messages [root@ecs-kafka bin]# 如需停止消费使用Ctrl+C命令退出。 父主题： 连接实例
min.cleanable.dirty.ratio、retention.bytes、file.delete.delay.ms、compression.type、flush.ms、cleanup.policy、unclean.leader.election.enable、flush.messages
topic_messages_remained 队列可消费消息数 消费组 告警阈值：原始值>积压上限的90%，积压上限由您根据业务实际情况设定 连续触发次数：1 告警级别：重要 该指标用于统计消费组指定队列可以消费的消息个数。
= int32(600) request.Body = &model.ResizeEngineInstanceReq{ NewStorageSpace: &newStorageSpaceResizeEngineInstanceReq, OperType: "storage
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
