查看迁移进度和结果

业务迁移过程中，确认旧集群的消息已被消费完毕之后，才能下线旧的集群。您可以参考本文档判断迁移的进度和迁移结果。

通过云监控查看

消息队列 Kafka版已接入云监控，您可以在云监控控制台直接查看生产和消费流量相关的监控指标，实时分析实例的运行状态。

1. 登录云监控控制台。

2. 在左侧导航栏中单击云产品监控，并在中间件区域中选择消息队列 Kafka版。

3. 单击实例名称，进入该实例的监控数据页面。
   指定时间范围之后，您可以通过以下指标判断实例的生产和消费状态。

   • 消息生产流量速率：当前集群每秒的生产流量，可以判断当前消息生产的速度。

   • 消息消费流量速率：当前集群每秒的消费流量，可以判断当前消息消费的速度。

   如果相关数据均显示为 0，说明没有持续生产和消费的行为，请确认生产者和消费者是否已成功接入。

通过命令行查看

您也可以参考以下步骤查看每个消费组的消费进度。

1. 执行以下命令，查询集群中的消费组列表。

   ./bin/kafka-consumer-groups.sh --bootstrap-server {kafkaAddress} --list
   

   

2. 执行以下命令，查询集群中指定消费组的消费进度。

   ./bin/kafka-consumer-groups.sh --bootstrap-server {kafkaAddress} --describe --group {group-name}
   

   其中，LAG 列即表示剩余可消费的消息数。如下图所示，当 LAG 列值为 0 时，则表示所有消息已被消费完毕。