选择project进入“协同消费”功能页面,选择日志库(logstore)后即可查看目前是否启用协同消费功能。

选择指定consumergroup之后,点击“消费状态”链接,即可查看当前每个shard消费数据的进度。
如上图所示,页面上展示该日志库包含5个shard,对应5个消费者,其中每个消费者最近消费的数据时间如第二列显示。通过消费数据时间可以判断出目前数据处理是否能满足数据产生速度,如果已经落后于当前时间(即数据消费速率小于数据产生速率),可以考虑重新启动程序,增加消费者数目。
<a href="https://help.aliyun.com/document_detail/28998.html">如何使用consumer library进行协同消费</a>
<a href="https://yq.aliyun.com/articles/35979">使用日志服务loghub替换kafka</a>