Este conteúdo foi traduzido por máquina para sua conveniência e a Huawei Cloud não pode garantir que o conteúdo foi traduzido com precisão. Para exibir o conteúdo original, use o link no canto superior direito para mudar para a página em inglês.
Atualizado em 2024-01-10 GMT+08:00

Consulta de detalhes do grupo de consumidores

Exibir a lista de grupos de consumidores, a lista de consumidores e os deslocamentos de consumidores.

Pré-requisitos

A lista de consumidores pode ser visualizada somente quando os consumidores de um grupo de consumidores estão conectados à instância do Kafka (isto é, o grupo de consumidores está no estado STABLE).

Exibir a lista de grupos de consumidores (console)

  1. Faça logon no console de gerenciamento.
  2. Clique em no canto superior esquerdo para selecionar uma região.

    Selecione a região onde sua instância do Kafka está localizada.

  3. Clique em e escolha Middleware > Distributed Message Service (for Kafka) para abrir o console do DMS for Kafka.
  4. Clique na instância de Kafka desejada para visualizar seus detalhes.
  5. No painel de navegação, escolha a guia Consumer Groups.

    O nome do grupo de consumidores, o status, o Coordenador (ID) e a descrição são exibidos.Coordenador (ID) indica o corretor onde o componente coordenador está localizado. O status do grupo de consumidores pode ser:

    • DEAD: o grupo de consumidores não tem nenhum membro ou metadados.
    • EMPTY: o grupo de consumidores tem metadados, mas não tem nenhum membro.
    • PREPARING_REBALANCE: o grupo de consumidores deve ser reequilibrado.
    • COMPLETING_REBALANCE: todos os membros aderiram ao grupo de consumidores.
    • STABLE: os membros do grupo de consumidores podem consumir mensagens normalmente.
    Figura 1 Lista de grupos de consumidores

  6. (Opcional) Para consultar um grupo de consumidores específico, informe o nome do grupo de consumidores na caixa de pesquisa e clique em .
  7. (Opcional) Para atualizar a lista de grupos de consumidores, clique em no canto superior direito.

Exibir a lista de grupos de consumidores (CLI de Kafka)

  • Se a SASL não estiver ativada para a instância do Kafka, execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para consultar a lista de grupos de consumidores:
    ./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --list
  • Se SASL tiver sido ativada para a instância do Kafka, execute os seguintes passos para consultar a lista de grupo de consumidores:
    1. (Opcional) Se a configuração do certificado SSL tiver sido definida, ignore esta etapa. Caso contrário, execute as seguintes operações:

      Crie o arquivo ssl-user-config.properties no diretório /config do cliente de Kafka e adicione as configurações de certificado SSL consultando 3.

    2. Execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para consultar a lista de grupo de consumidores:
      ./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --list --command-config ./config/ssl-user-config.properties 

Exibir a lista de consumidores (console)

  1. Faça logon no console de gerenciamento.
  2. Clique em no canto superior esquerdo para selecionar uma região.

    Selecione a região onde sua instância do Kafka está localizada.

  3. Clique em e escolha Middleware > Distributed Message Service (for Kafka) para abrir o console do DMS for Kafka.
  4. Clique na instância de Kafka desejada para visualizar seus detalhes.
  5. No painel de navegação, escolha a guia Consumer Groups.
  6. Clique no nome do grupo de consumidores desejado.
  7. Na página de guia Consumers, visualize a lista de consumidores.

    Na lista de consumidores, você pode exibir o ID do consumidor, o endereço do consumidor e o ID do cliente.

  8. (Opcional) Para consultar um consumidor específico, insira o ID do consumidor na caixa de pesquisa e clique em .

Exibir a lista de consumidores (CLI de Kafka)

  • Se a SASL não estiver habilitada para a instância do Kafka, execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para consultar a lista de consumidores:
    ./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --group {group_name} --members --describe
  • Se SASL tiver sido ativada para a instância do Kafka, execute as seguintes etapas para consultar a lista de consumidores:
    1. (Opcional) Se a configuração do certificado SSL tiver sido definida, ignore esta etapa. Caso contrário, execute as seguintes operações:

      Crie o arquivo ssl-user-config.properties no diretório /config do cliente de Kafka e adicione as configurações de certificado SSL consultando 3.

    2. Execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para consultar a lista de consumidores:
      ./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --group {group_name} --members --describe --command-config ./config/ssl-user-config.properties 

Exibir deslocações do consumidor (console)

  1. Faça logon no console de gerenciamento.
  2. Clique em no canto superior esquerdo para selecionar uma região.

    Selecione a região onde sua instância do Kafka está localizada.

  3. Clique em e escolha Middleware > Distributed Message Service (for Kafka) para abrir o console do DMS for Kafka.
  4. Clique na instância de Kafka desejada para visualizar seus detalhes.
  5. No painel de navegação, escolha a guia Consumer Groups.
  6. Clique no nome do grupo de consumidores desejado.
  7. Na página de guia Consumer Offset, exiba a lista de tópicos que o grupo de consumidores se inscreveu, número total de mensagens acumuladas no tópico, progresso do consumo de mensagens em cada partição do tópico (mensagens acumuladas, deslocamento, deslocamento mais recente, ID do consumidor, endereço do consumidor e ID do cliente).

    Figura 2 Progresso do consumo

  8. (Opcional) Para consultar os deslocamentos do consumidor de um tópico específico, digite o nome do tópico na caixa de pesquisa e clique em .

Exibir deslocamentos do consumidor (CLI de Kafka)

  • Se a SASL não estiver habilitada para a instância do Kafka, execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para consultar deslocamentos do consumidor:
    ./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --offsets --describe --all-groups
  • Se SASL tiver sido ativada para a instância do Kafka, execute as seguintes etapas para consultar os deslocamentos do consumidor:
    1. (Opcional) Se a configuração do certificado SSL tiver sido definida, ignore esta etapa. Caso contrário, execute as seguintes operações:

      Crie o arquivo ssl-user-config.properties no diretório /config do cliente de Kafka e adicione as configurações de certificado SSL consultando 3.

    2. Execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para consultar deslocamentos do consumidor:
      ./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --offsets --describe --all-groups --command-config ./config/ssl-user-config.properties