When message accumulation or skewing occurs, you can view the subscriptions between consumer groups and topics and determine the status based on the consumption progress of each partition.

View consumer groups that subscribe to a topic

  1. Log on to the Message Queue for Apache Kafka console.
  2. In the top navigation bar, select the region where the instance that contains the topic is located.
  3. In the left-side navigation pane, click Topics.
  4. On the Topics page, click the instance, find the topic, click More in the Actions column, and then select Subscription Relationship.
    In the Subscription Relationship dialog box, all the consumer groups that subscribe to the topic appear.Subscriptions
  5. In the Consumer Group column, find the consumer group whose consumption status you want to view and click Details in the Actions column.

    The message consumption details in each partition of the topic appear.

    Subscriptions
    Parameter Description
    Partition ID The ID of the partition corresponding to the topic.
    owner The ID and IP address of the online consumer that has subscribed to the topic are displayed in real time.
    Note
    • The value format is <Client ID>_/<IP address>.
    • You cannot view the owner information of offline consumers.
    Maximum Offset The maximum message consumer offset of the topic in the current partition.
    Consumer Offset The message consumer offset of the topic in the current partition.
    Messages Accumulated The total number of accumulated messages in the current partition. The value is equal to the maximum offset minus the consumer offset.
    Notice Messages Accumulated is a key metric. If a large number of messages are accumulated, the consumer may be blocked or the consumption speed cannot keep up with the production speed. If this is the case, you need to analyze the consumer running status and improve the consumption speed. For more information, see Reset consumer offsets.
    Last Consumed At The time when the last message consumed by the consumer group was sent to the broker for storage.

View topics to which a consumer group subscribes

  1. Log on to the Message Queue for Apache Kafka console.
  2. In the top navigation bar, select the region where the instance that contains the consumer group is located.
  3. In the left-side navigation pane, click Consumer Groups.
  4. On the Consumer Groups page, click the instance, find the consumer group, and then click Consumption Status in the Actions column.
    In the Consumption Status dialog box, all the topics to which the consumer group has subscribed and the Messages Accumulatedand Last Consumed At of each topic appear.Consumption status
  5. In the Topic column, find the topic whose consumption status you want to view and click Details in the Actionscolumn.
    The message consumption details in each partition of the topic appear.Consumption status details
    Parameter Description
    Partition ID The ID of the partition corresponding to the topic.
    owner The ID and IP address of the online consumer that has subscribed to the topic are displayed in real time.
    Note
    • The value format is <Client ID>_/<IP address>.
    • You cannot view the owner information of offline consumers.
    Maximum Offset The maximum message consumer offset of the topic in the current partition.
    Consumer Offset The message consumer offset of the topic in the current partition.
    Messages Accumulated The total number of accumulated messages in the current partition. The value is equal to the maximum offset minus the consumer offset.
    Notice Messages Accumulated is a key metric. If a large number of messages are accumulated, the consumer may be blocked or the consumption speed cannot keep up with the production speed. If this is the case, you need to analyze the consumer running status and improve the consumption speed. For more information, see Reset consumer offsets.
    Last Consumed At The time when the last message consumed by the consumer group was sent to the broker for storage.