消息服务for Kafka-专享版 消息服务 for Kafka-专享版包含5种监控对象类型,分别是:服务监控(Broker)、主题监控(Topic)、主机监控(Node)、集群监控(Cluster)、消费组监控(ConsumerGroup),各个类型包含的监控指标列表如下: 服务监控(Broker) 指标英文名称(metric name) 指标中文名称 单位 维度 备注 ActiveControllerCount
MessagePublishRateQueue 队列发布消息速度 条/秒 InstanceId,QueueName Messages 实例消息数 条 InstanceId MessagesReady 实例可消费消息数 条 InstanceId MessagesReadyQueue 队列可消费消息数 条 InstanceId,QueueName MessagesUnacknowledged 实例未确认消息数
消息队列和事件驱动架构 Kafka可以作为消息队列使用,用于处理异步消息和事件驱动的架构,支持消息的发布订阅和消息的队列处理。 大数据处理和流处理 Kafka可以与大数据处理框架如Hadoop、Spark、Flink等集成,支持大规模数据的处理和分析,实现实时数据流处理和批处理任务。
删除消费组 操作场景 用于删除集群中不再使用的消费组。 前提条件 集群必须处于 服务中 状态。 删除消费组时,需要确保该消费组内没有消费者正在运行,否则会删除失败。 注意事项 删除消费组后,该消费组所有的消费信息会被删除并且无法恢复,请谨慎操作。 操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面。单击需要操作的集群名称,进入集群详情界面。
消息查询 操作场景 用于在控制台中根据时间或者位点来查询主题中的消息。 注意事项 支持查询结果最多显示20条消息,且总大小不超过10MB。 每10秒可查询一次。 操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,单击需要操作的集群进入集群详情。
前提条件 集群必须处于 服务中 状态。 消费组重置位点时,需要确保该消费组内没有消费者正在运行,否则会操作失败。 操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,单击需要操作的集群进入集群详情界面。 在 消费组管理 页面,在需要重置位带你的消费组右侧单击 重置位点 按钮,填写需要重置的主题和分区,并且选择重置策略进行重置。
死信队列:RabbitMQ支持消费失败消息、TTL过期消息、队列长度超限消息进入死信队列,且不重新发送到原来的队列消费,保证消息不丢失。 延时队列:RabbitMQ支持消息延时/定时发送,满足用户多个场景下的需求。
操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面。单击需要操作的集群进入集群详情。 在侧边导航单击 消费组管理 进入页面能看到集群中的消费组列表。 单击具体的消费组名称可以查看当前消费组所订阅的主题列表。 单击 查看详情 按钮可以查看当前消费组在对应主题中的具体消费情况。
开启自定义消息通知 在接收Sugar BI 的 定时推送 和 数据预警 ,除了邮箱、群机器人和 APP 通知外,还支持一种额外的自定义消息通知方式(部署的 Sugar BI 版本需要是 5.0.2 及以上),例如要把消息通过短信的方式发送给接收者,这种情况则可以使用这种方式进行消息通知。
消息生产 Plain Text 复制 1 mqadmin sendMessage --namesrvAddr <RocketMQ接入点> --topic <主题名> --body <消息内容> 生产成功后客户端会输出消息写入的节点名、队列ID、发送结果以及消息ID,如下所示: 生产成功后客户端会输出消息写入的节点名、队列ID、发送结果以及消息ID,如下所示: 消息消费