1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
class collectd::plugin::write_kafka (
$ensure = 'present',
$kafka_host = undef,
Array[String] $kafka_hosts = ['localhost:9092'],
$kafka_port = 9092,
Hash $topics = {},
) {
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'),
}
}
|
