Puppet Class: collectd::plugin::write_kafka

Defined in:
manifests/plugin/write_kafka.pp

Overview

Parameters:

  • ensure (Any) (defaults to: 'present')
  • kafka_host (Any) (defaults to: undef)
  • kafka_hosts (Any) (defaults to: ['localhost:9092'])
  • kafka_port (Any) (defaults to: 9092)
  • topics (Any) (defaults to: {})
  • interval (Any) (defaults to: undef) 


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'manifests/plugin/write_kafka.pp', line 1

class collectd::plugin::write_kafka (
  $ensure     = 'present',
  $kafka_host = undef,
  $kafka_hosts = ['localhost:9092'],
  $kafka_port = 9092,
  $topics     = {},
  $interval   = undef,
) {

  include ::collectd

  validate_hash($topics)
  validate_array($kafka_hosts)

  if($kafka_host and $kafka_port) {
    $real_kafka_hosts = [ "${kafka_host}:${kafka_port}" ]
  } else {
    $real_kafka_hosts = $kafka_hosts
  }
  $kafka_broker = join($real_kafka_hosts, ',')

  collectd::plugin { 'write_kafka':
    ensure   => $ensure,
    content  => template('collectd/plugin/write_kafka.conf.erb'),
    interval => $interval,
  }
}