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 (Array[String]) (defaults to: ['localhost:9092'])
  • kafka_port (Stdlib::Port) (defaults to: 9092)
  • topics (Hash) (defaults to: {})
  • properties (Hash) (defaults to: {})
  • meta (Hash) (defaults to: {}) 


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

class collectd::plugin::write_kafka (
  $ensure                    = 'present',
  $kafka_host                = undef,
  Array[String] $kafka_hosts = ['localhost:9092'],
  Stdlib::Port $kafka_port   = 9092,
  Hash $topics               = {},
  Hash $properties           = {},
  Hash $meta                 = {},
) {
  include collectd

  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'),
  }
}