Skip to content

Helper for exposing rdkafka 'statistics' through prometheus

License

Notifications You must be signed in to change notification settings

wikimedia/node-rdkafka-prometheus

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

48 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

node-rdkafka-prometheus Build Status

Helper for exposing node-rdkafka statistics through prometheus

Fork of Collaborne/node-rdkafka-prometheus for use at the Wikimedia Foundation.

Usage

const RdkafkaPrometheus = require('node-rdkafka-prometheus');
const prometheus = require('prom-client');

const rdkafkaPrometheus= new RdkafkaPrometheus({
  // It is recommended that you pass in your require of prom-client to
  // RdkafkaPrometheus, as prom-client does not work well when it is required
  // more than once in the same process.
  // If you don't provide this, RdkafkaPrometheus will require('prom-client') itself.
  prometheus: prometheus, // optional
  extraLabels: { my_custom_label: 'label_value' },  // optional
  namePrefix: 'metric_name_prefix'  // optional
  // registers: [prometheus.register] // optional, this is the default.
})

// When setting up a consumer or producer:
const stream = rdkafka.KafkaConsumer.createReadStream({'statistics.interval.ms': 1000});
stream.consumer.on('event.stats', msg => {
  const stats = JSON.parse(msg.message);
  // Optional: override the default label value for any declared extraLabels.
  // If you use extraLabels here, the keys must have already been declared
  // in the extraLables RdkafaStats contructor option.
  const extraLabels = { my_custom_label: 'special_label_value' };
  rdkafkaPrometheus.observe(stats, extraLabels);
});

License

This software is licensed under the Apache 2 license, quoted below.

    Copyright 2011-2020 Collaborne B.V. <http://github.com/Collaborne/>

    Licensed under the Apache License, Version 2.0 (the "License"); you may not
    use this file except in compliance with the License. You may obtain a copy of
    the License at

        http://www.apache.org/licenses/LICENSE-2.0

    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
    License for the specific language governing permissions and limitations under
    the License.

About

Helper for exposing rdkafka 'statistics' through prometheus

Resources

License

Code of conduct

Stars

Watchers

Forks

Packages

No packages published

Languages

  • JavaScript 100.0%