Apache Kafka verificações e políticas padrão

  • Versão de lançamento: Zurich
  • Atualizado 31 de jul. de 2025
  • 3 min. de leitura
  • Agent Client Collector fornece as seguintes políticas para Apache Kafka monitoramento de integridade. As políticas vêm com as verificações especificadas na tabela indicada. As políticas e verificações estão disponíveis para ambos Windows e. Linux.

    Tabela 1. Apache Kafka Eventos de tópico
    Verificação Descrição Uso Saída
    kafka.check-zookeeper-status Gera um evento crítico se o Kafka Zookeeper hospedado estiver inativo. check-kafka-zk-status [sinalizadores]

    Onde os sinalizadores são:

    -p, --port Porta do Zookeeper (padrão "2181").

    Exemplo de uso: check-kafka-zk-status -p 2181

    Kafka Zookeeper Status OK: Kafka Zookeeper está ativo!
    kafka.check-topic-replicas Gera um evento crítico se algum tópico tiver partições com réplicas desconhecidas. check-kafka-replicas comuns [sinalizadores]

    Onde os sinalizadores são:

    • -p, --port Porta do Zookeeper (padrão "2181").
    • -d, --detailed Lista réplicas desconhecidas em cada partição de um tópico.
    • -i, --include_list Lista separada por vírgulas para incluir tópicos (permite * caractere curinga)
    • -e, --exclude_list Lista separada por vírgulas para excluir tópicos (permite * caractere curinga)
    Exemplo de uso: Commonchecks check-kafka-replicas -H localhost -p 2181 -i "test*" -e "accTopic,*offsets" -d

    o <topic> tem partições com réplicas desconhecidas. Réplicas desconhecidas são:["0":["0"],"1":["0"],"2":["0"].

    o <topic> tem partições com réplicas desconhecidas. Réplicas desconhecidas são:["0":["0"].

    kafka.check-topic-replication-factor Gera um evento crítico se o fator de replicação de pelo menos um tópico estiver acima ou abaixo do parâmetro do fator de replicação fornecido. check-kafka-rf [sinalizadores]

    Onde os sinalizadores são:

    • -p, --port Porta do Zookeeper (padrão "2181").
    • -d, --detailed Lista réplicas desconhecidas em cada partição de um tópico.
    • -i, --include_list Lista separada por vírgulas para incluir tópicos (permite * caractere curinga)
    • -e, --exclude_list Lista separada por vírgulas para excluir tópicos (permite * caractere curinga)
    • fator -r, --replication Fator de replicação esperado para um tópico (padrão 1)

    Exemplos: Check-kafka-partições -H localhost -p 2181 -r 2 -i "accMetrics,*topic" -e "testTopic"

    TestTopic tem fator de replicação 1, que é menor do que o esperado: 2.

    O accMetrics tem fator de replicação 1, que é menor do que o esperado: 2.

    kafka.check-topic-leader Gera um evento crítico se algum tópico tiver partições com líderes desconhecidos ou réplica não preferencial como líder. check-kafka-leader [sinalizadores]

    Onde estão os sinalizadores

    • -p, --port Porta do Zookeeper (padrão "2181").
    • -d, --detailed Uma lista de partições em cada tópico com líderes desconhecidos ou réplicas não preferenciais.
    • -i, --include_list Lista separada por vírgulas para incluir tópicos (permite * caractere curinga)
    • -e, --exclude_list Lista separada por vírgulas para excluir tópicos (permite * caractere curinga)

    Exemplos:

    Check-kafka-leader -H localhost -p 2181 -d -e "*offsets"

    o <topic> contém partições com réplica não preferencial como líder. (as partições com réplicas não preferenciais são [0]).

    o <topic> contém partições com réplica não preferencial como líder. (as partições com réplicas não preferenciais são [0]).

    kafka.check-topic-partitions Gera eventos críticos se o número de partições de um tópico for menor que o parâmetro min_partitions. check-kafka-partitions [sinalizadores]

    Onde os sinalizadores são:

    • -p, --port Porta do Zookeeper (padrão "2181").
    • -P, --min_partitions Mínimo de partições para um tópico (padrão 1).
    • -i, --include_list Lista separada por vírgulas para incluir tópicos (permite * caractere curinga)
    • -e, --exclude_list Lista separada por vírgulas para excluir tópicos (permite * caractere curinga)

    Exemplo de uso 1: Check-kafka-partições -H localhost -p 2181 -P 3

    o <topic> tem 1 partições, esperadas pelo menos 3.

    o <topic> tem 1 partições, esperadas pelo menos 3.

    o <topic> tem 1 partições, esperadas pelo menos 3.

    Exemplo de uso 2: Commonchecks check-kafka-partitions -H localhost -p 2181 -P 3 -i "accMetrics,*topic" -e "testTopic"

    o <topic> tem 1 partições, esperadas pelo menos 3.

    o <topic> tem 1 partições, esperadas pelo menos 3.

    Nota:
    Os valores dos parâmetros include_list e exclude_list precisam ser encapsulados entre aspas duplas. Por exemplo: "Test1,*topic".
    Tabela 2. Apache Kafka Eventos do agente
    Verificação Descrição Uso Saída
    kafka.check-broker-status Gera um evento crítico se o agente Kafka no host estiver inativo. check-kafka-broker-status [sinalizadores]

    Onde os sinalizadores são:

    -p, --port Porta do agente Kafka (padrão "9092").

    Exemplo de uso: check-kafka-broker-status -p 9092

    Kafka Broker Status OK: Kafka Broker ubuntu20:9092 está ativo!
    Tabela 3. Apache Kafka Métricas do agente
    Verificação Descrição Uso Saída
    kafka.metrics.broker Coleta métricas do agente Kafka do host. métrica-kafka-broker [sinalizadores]
    Onde os sinalizadores são:
    • -J, --javapath Caminho executável Java (padrão "java").
    • -j, --jmxport Porta JMX (padrão "9999")

    Exemplo de uso: Commonchecks metric-kafka-broker -J "/usr/bin/java" -j 9999

    Kafka.Broker.ReplicaManager.IsrExpandsPerSec.OneMinuteRate 0,000

    Kafka.Broker.DefationOperationPurgatory.Purgatory.PurgatorySize.Fetch.Value 627,000

    Kafka.Broker.ControllerStats.UncleLeaderElectionsPerSec.OneMinuteRate 0,000

    Kafka.Broker.SolicitMetrics.SolicitsPerSec.Produce.OneMinuteRate 0,000

    Tabela 4. Apache Kafka Métricas do Zookeeper
    Verificação Descrição Uso Saída
    kafka.metrics.zookeeper Coleta métricas do Zookeeper do host. commonverifica métrica-kafka-zookeeper [sinalizadores]

    Onde o sinalizador é: -p, --adminserverport Porta do servidor de administração (padrão "8085")

    Exemplo de uso: commonchecks metric-kafka-zookeeper -p 8085

    Kafka.Zookeeper.outstanding_Requests 2,000 1648183249

    Kafka.Zookeeper.avg_latency 1,05 1648183249

    Kafka.Zookeeper.num_alive_connections 1,000 1648183249

    Kafka.Zookeeper.open_file_descritor_count 124,000 1648183249