How to monitor HiveMQ Enterprise Extension for Kafka

This article provides a comprehensive guide on monitoring the HiveMQ Enterprise Extension for Kafka by leveraging specific HiveMQ metrics. It details the various metrics available for tracking the performance and activity of Kafka mappings or transformers, such as message counts, latency, and error rates. Users are instructed on how to replace placeholders with actual mapping IDs from the config.xml configuration file to accurately monitor and analyze the performance of their Kafka integration.

 Instructions

There are HiveMQ metrics allowing to monitor per-mapping (or per-transformer):

  • com_hivemq_extension_consumer_messages_incoming_kafka_extension_($kafka_mapping)_count

  • com_hivemq_extension_consumer_messages_processed_kafka_extension_($kafka_mapping)_count

  • kafka_extension_topic_mapping_($kafka_mapping)_failed_count

  • kafka_extension_topic_mapping_($kafka_mapping)_latency

  • kafka_extension_topic_mapping_($kafka_mapping)_latency_count

  • kafka_extension_topic_mapping_($kafka_mapping)_latency_sum

  • kafka_extension_topic_mapping_($kafka_mapping)_retry_count

  • kafka_extension_topic_mapping_($kafka_mapping)_send_count

  • kafka_extension_topic_mapping_($kafka_mapping)_success_count

Replace ($kafka_mapping) with the mapping id (transformer id) from the kafka-configuration config.xml

 Related articles