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