Puppet Class: profile::rsyslog::netdev_kafka_relay

Defined in:
modules/profile/manifests/rsyslog/netdev_kafka_relay.pp

Overview

Parameters:

  • logging_kafka_brokers (Array) (defaults to: lookup('profile::rsyslog::kafka_shipper::kafka_brokers'))
  • port (Integer) (defaults to: lookup('profile::rsyslog::netdev_kafka_relay_port', {'default_value' => 10514}))
  • queue_enabled_sites (Array[String]) (defaults to: lookup('profile::rsyslog::kafka_queue_enabled_sites', {'default_value' => []}))


10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
# File 'modules/profile/manifests/rsyslog/netdev_kafka_relay.pp', line 10

class profile::rsyslog::netdev_kafka_relay (
    Array $logging_kafka_brokers = lookup('profile::rsyslog::kafka_shipper::kafka_brokers'),
    Integer $port = lookup('profile::rsyslog::netdev_kafka_relay_port', {'default_value' => 10514}),
    Array[String] $queue_enabled_sites = lookup('profile::rsyslog::kafka_queue_enabled_sites',
                                                {'default_value' => []}),
) {
    ensure_packages('rsyslog-kafka')

    $queue_size = $::site in $queue_enabled_sites ? {
        true  => 10000,
        false => 0,
    }

    include profile::base::certificates
    $trusted_ca_path = $profile::base::certificates::trusted_ca_path
    rsyslog::conf { 'netdev_kafka_relay':
        content  => template('profile/rsyslog/netdev_kafka_relay.conf.erb'),
        priority => 50,
        instance => 'receiver',
    }

    # Templates required by netdev_kafka_relay output
    rsyslog::conf { 'template_syslog_json_receiver':
        source   => 'puppet:///modules/profile/rsyslog/template_syslog_json.conf',
        priority => 10,
        instance => 'receiver',
    }
}