业务迁移过程中,确认旧集群的消息已被消费完毕之后,才能下线旧的集群。您可以参考本文档判断迁移的进度和迁移结果。
消息队列 Kafka版已接入云监控,您可以在云监控控制台直接查看生产和消费流量相关的监控指标,实时分析实例的运行状态。
登录云监控控制台。
在左侧导航栏中单击云产品监控,并在中间件区域中选择消息队列 Kafka版。
单击实例名称,进入该实例的监控数据页面。
指定时间范围之后,您可以通过以下指标判断实例的生产和消费状态。
消息生产流量速率:当前集群每秒的生产流量,可以判断当前消息生产的速度。
消息消费流量速率:当前集群每秒的消费流量,可以判断当前消息消费的速度。
如果相关数据均显示为 0,说明没有持续生产和消费的行为,请确认生产者和消费者是否已成功接入。
您也可以参考以下步骤查看每个消费组的消费进度。
执行以下命令,查询集群中的消费组列表。
./bin/kafka-consumer-groups.sh --bootstrap-server {kafkaAddress} --list
执行以下命令,查询集群中指定消费组的消费进度。
./bin/kafka-consumer-groups.sh --bootstrap-server {kafkaAddress} --describe --group {group-name}
其中,LAG 列即表示剩余可消费的消息数。如下图所示,当 LAG 列值为 0 时,则表示所有消息已被消费完毕。