Skip to content

Kafka Topic

Kafka Topic Monitor is designed to verify the existence of specified topics within a Kafka queue. By querying the Kafka cluster, this monitor ensures that the specified topics are present and accessible, providing critical insights into the operational state of your Kafka infrastructure.

label: language:python; os:alma8

Configuration

Required

  • Zone Type: Select "kafkatopic_monitor" when creating a Kafka Topic Monitor zone under the plugin domain.

Server Configuration

  • Server Type: Select "kafkatopic_monitor" when creating a server under the Kafka Topic Monitor zone.
  • Server IP Address: Input the server address in the format hostname:port, e.g., rpbt1hsn008.webex.com:9092.
  • Server Hostname: This parameter is not used in the monitor; you can input any value here.

Optional

  • Select List: Choose the mode between "blocklist" or "allowlist".
  • List Content: Input the topics according to the selected mode, formatted as a comma-separated list, e.g., clap_bt4_special_messenger,clap_bt2_special_meeting.
  • Timeout: Specify the query timeout for each list, with the default being 3 seconds.

Result

  • Success: If the target service is operational, the monitor will return 0 and output "success".
  • Failure: If there are issues, the monitor will output the problematic topics in a table format.

By setting up the Kafka Topic Monitor in MCT with the correct configuration, you can ensure that your Kafka topics are accessible and functioning as expected, enabling proactive management and troubleshooting of your Kafka infrastructure.

Source Code
More details could be found in kafkaTopic Monitor