--- sourceDocument: Australia IT Operations Management sourceDocumentLink: https://www.servicenow.com/docs/r/it-operations-management Release : - australia ft:locale : - en-US ft:publication_title : - Australia IT Operations Management ft:clusterId : - itom bundleId : - itom workflow : - Technology --- # Apache Kafka default checks and policies # Apache Kafka default checks and policies {#ariaid-title1} * Release version: Australia * * Updated March 12, 2026 * * ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 3 minutes to read Summarize ![AI sparkle icon](https://servicenow.com/docs/portal-asset/ai-sparkle-icon) Summarized using AI This content was generated using new OpenAI-powered functionality. Results are provided on an as is basis and are not guaranteed to be accurate or complete. ## Summary of Apache Kafka Default Checks and Policies The Agent Client Collector offers various health monitoring policies for Apache Kafka, applicable to both Windows and Linux environments. These policies include checks that help monitor Kafka's status, replication factors, leader assignments, and partition counts, ensuring optimal performance and reliability. Show full answer Show less ## Key Features * **Kafka Zookeeper Status Check:** Monitors the health of the Kafka Zookeeper. A critical event is raised if it is down. Command: `commonchecks check-kafka-zk-status -p 2181`. * **Topic Replicas Check:** Identifies topics with unknown replicas, raising critical events as needed. Command: `commonchecks check-kafka-replicas -H localhost -p 2181 -i "test" -e "accTopic,offsets" -d`. * **Replication Factor Check:** Alerts if any topic's replication factor deviates from the specified parameter. Command: `commonchecks check-kafka-rf -H localhost -p 2181 -r 2`. * **Topic Leader Check:** Raises events for topics with unknown leaders or unpreferred replicas. Command: `commonchecks check-kafka-leader -H localhost -p 2181 -d`. * **Topic Partitions Check:** Checks if the number of partitions for a topic falls below a defined minimum. Command: `commonchecks check-kafka-partitions -H localhost -p 2181 -P 3`. * **Broker Status Check:** Monitors the status of the Kafka Broker, raising alerts if it is down. Command: `commonchecks check-kafka-broker-status -p 9092`. * **Broker Metrics Collection:** Gathers performance metrics from the Kafka Broker. Command: `commonchecks metric-kafka-broker -J "/usr/bin/java" -j 9999`. * **Zookeeper Metrics Collection:** Collects metrics from the Zookeeper instance. Command: `commonchecks metric-kafka-zookeeper -p 8085`. ## Key Outcomes By implementing these checks, ServiceNow customers can proactively monitor the health of their Apache Kafka environments, ensuring high availability and performance. This enables timely identification of issues, leading to quick resolutions and improved operational efficiency. Agent Client Collector provides the following policies for Apache Kafka health monitoring. Policies come with the checks specified in the indicated table. Policies and checks are available for both Windows and Linux. {#kafka-checks-policies__table_y3r_2qd_2tb__entry__4} | Check | Description | Usage | Output | |-|-|-|-| | kafka.check-zookeeper-status | Raises a critical event if the hosted Kafka Zookeeper is down. | `commonchecks check-kafka-zk-status` \[flags\] Where the flags are: `-p, --port =` Zookeeper Port (default "2181"). Usage example: `commonchecks check-kafka-zk-status -p 2181` | Kafka Zookeeper Status OK: Kafka Zookeeper is Up! | | kafka.check-topic-replicas | Raises critical event if any topic has partitions with unknown replicas. | `commonchecks check-kafka-replicas ` \[flags\] Where the flags are: * `-p, --port =` Zookeeper Port (default "2181"). * `-d, --detailed` = Lists unknown replicas in each partition of a topic. * `-i, --include_list` = Comma seperated list to include topics (allows \* wild character) * `-e, --exclude_list` = Comma seperated list to exclude topics (allows \* wild character) {#kafka-checks-policies__ul_wtk_yhl_25b}Usage example: commonchecks check-kafka-replicas -H localhost -p 2181 -i "test\*" -e "accTopic,\*offsets" -d | \ has partitions with unknown replicas. Unknown replicas are: {"0":\["0"\],"1":\["0"\],"2":\["0"\]}. \ has partitions with unknown replicas. Unknown replicas are: {"0":\["0"\]}. | | kafka.check-topic-replication-factor | Raises critical event if replication factor of at least one topic is above or below provided replication factor param. | `commonchecks check-kafka-rf` \[flags\] Where the flags are: * `-p, --port =` Zookeeper Port (default "2181"). * `-d, --detailed` = Lists unknown replicas in each partition of a topic. * `-i, --include_list` = Comma separated list to include topics (allows \* wild character) * `-e, --exclude_list` = Comma separated list to exclude topics (allows \* wild character) * `-r, --replication factor` = Expected replication factor for a topic (default 1) {#kafka-checks-policies__ul_gcn_mcm_f5b} Examples: `commonchecks check-kafka-partitions -H localhost -p 2181 -r 2 -i "accMetrics,*Topic" -e "testTopic"` | TestTopic has replication factor 1, which is less than expected: 2. accMetrics has replication factor 1, which is less than expected: 2. | | kafka.check-topic-leader | Raises critical event if any topic has partitions with unknown leaders or unpreferred replica as leader. | `commonchecks check-kafka-leader` \[flags\] Where the flags are * `-p, --port` = Zookeeper Port (default "2181"). * `-d, --detailed` = A list of partitions in each topic with unknown leaders or unpreferred replicas. * `-i, --include_list` = Comma separated list to include topics (allows \* wild character) * `-e, --exclude_list` =Comma separated list to exclude topics (allows \* wild character) {#kafka-checks-policies__ul_bqh_gdm_f5b} Examples: `commonchecks check-kafka-leader -H localhost -p 2181 -d -e "*offsets"` | \ contains, partitions with unpreferred replica as leader.(partitions with unpreferred replicas are \[0\]). \ contains, partitions with unpreferred replica as leader.(partitions with unpreferred replicas are \[0\]). | | kafka.check-topic-partitions | Raises critical events if number of partitions for a topic is less the min_partitions param. | `commonchecks check-kafka-partitions [flags]` Where the flags are: * `-p, --port` = Zookeeper Port (default "2181"). * `-P, --min_partitions` = Minimum partitions for a topic (default 1). * `-i, --include_list` = Comma separated list to include topics (allows \* wild character) * `-e, --exclude_list` =Comma separated list to exclude topics (allows \* wild character) {#kafka-checks-policies__ul_q5g_xxd_2tb} | | | kafka.check-topic-partitions | Raises critical events if number of partitions for a topic is less the min_partitions param. | Usage example 1: `commonchecks check-kafka-partitions -H localhost -p 2181 -P 3` | \ has 1 partitions, expected at least 3. \ has 1 partitions, expected at least 3. \ has 1 partitions, expected at least 3. | | kafka.check-topic-partitions | Raises critical events if number of partitions for a topic is less the min_partitions param. | Usage example 2: commonchecks check-kafka-partitions -H localhost -p 2181 -P 3 -i "accMetrics,\*Topic" -e "testTopic" | \ has 1 partitions, expected at least 3. \ has 1 partitions, expected at least 3. | [Table 1. Apache Kafka Topic Events] {#kafka-checks-policies__table_y3r_2qd_2tb} Note: Values for include_list and exclude_list parameters have to be wrapped between double quotes. For example: "test1,\*topic". {#kafka-checks-policies__table_hxk_5dm_f5b__entry__4} | Check | Description | Usage | Output | |-|-|-|-| | kafka.check-broker-status | Raises critical event if Kafka Broker on the host is down. | `commonchecks check-kafka-broker-status` \[flags\] Where the flags are: `-p, --port` = Kafka Broker port (default "9092"). Usage example: `commonchecks check-kafka-broker-status -p 9092` | Kafka Broker Status OK: Kafka Broker ubuntu20:9092 is Up! | [Table 2. Apache Kafka Broker Events] {#kafka-checks-policies__table_hxk_5dm_f5b} {#kafka-checks-policies__table_emg_g2m_f5b__entry__4} | Check | Description | Usage | Output | |-|-|-|-| | kafka.metrics.broker | Collects Kafka Broker Metrics from the host. | ` commonchecks metric-kafka-broker` \[flags\] Where the flags are: * `-J, --javapath ` = Java executable path (default "java"). * `-j, --jmxport` = JMX Port (default "9999") {#kafka-checks-policies__ul_xjm_z2m_f5b} Usage example: `commonchecks metric-kafka-broker -J "/usr/bin/java" -j 9999` | hostname.Kafka.Broker.ReplicaManager.IsrExpandsPerSec.OneMinuteRate 0.000 hostname.Kafka.Broker.DelayedOperationPurgatory.PurgatorySize.Fetch.Value 627.000 hostname.Kafka.Broker.ControllerStats.UncleanLeaderElectionsPerSec.OneMinuteRate 0.000 hostname.Kafka.Broker.RequestMetrics.RequestsPerSec.Produce.OneMinuteRate 0.000 | [Table 3. Apache Kafka Broker Metrics] {#kafka-checks-policies__table_emg_g2m_f5b} {#kafka-checks-policies__table_ds2_3fm_f5b__entry__4} | Check | Description | Usage | Output | |-|-|-|-| | kafka.metrics.zookeeper | Collects Zookeeper Metrics from the host. | ` commonchecks metric-kafka-zookeeper` \[flags\] Where the flag is: `-p, --adminserverport `= Admin Server Port (default "8085") Usage example: `commonchecks metric-kafka-zookeeper -p 8085` | hostname.Kafka.Zookeeper.outstanding_requests 2.000 1648183249 hostname.Kafka.Zookeeper.avg_latency 1.05 1648183249 hostname.Kafka.Zookeeper.num_alive_connections 1.000 1648183249 hostname.Kafka.Zookeeper.open_file_descriptor_count 124.000 1648183249 | [Table 4. Apache Kafka Zookeeper Metrics] {#kafka-checks-policies__table_ds2_3fm_f5b}