Puppet Class: kafka::broker::config

Defined in:
manifests/broker/config.pp

Overview

Class: kafka::broker::config

This private class is meant to be called from ‘kafka::broker`. It manages the broker config files

Parameters:

  • config_dir (Stdlib::Absolutepath) (defaults to: $kafka::broker::config_dir)
  • service_name (String) (defaults to: $kafka::broker::service_name)
  • service_install (Boolean) (defaults to: $kafka::broker::service_install)
  • service_restart (Boolean) (defaults to: $kafka::broker::service_restart)
  • config (Hash) (defaults to: $kafka::broker::config)
  • config_mode (Stdlib::Filemode) (defaults to: $kafka::broker::config_mode)
  • group (String) (defaults to: $kafka::broker::group) 


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
38
39
40
 
# File 'manifests/broker/config.pp', line 10

class kafka::broker::config(
  Stdlib::Absolutepath $config_dir = $kafka::broker::config_dir,
  String $service_name             = $kafka::broker::service_name,
  Boolean $service_install         = $kafka::broker::service_install,
  Boolean $service_restart         = $kafka::broker::service_restart,
  Hash $config                     = $kafka::broker::config,
  Stdlib::Filemode $config_mode    = $kafka::broker::config_mode,
  String $group                    = $kafka::broker::group,
) {

  if ($caller_module_name != $module_name) {
    fail("Use of private class ${name} by ${caller_module_name}")
  }

  if ($service_install and $service_restart) {
    $config_notify = Service[$service_name]
  } else {
    $config_notify = undef
  }

  $doctag = 'brokerconfigs'
  file { "${config_dir}/server.properties":
    ensure  => present,
    owner   => 'root',
    group   => $group,
    mode    => $config_mode,
    content => template('kafka/properties.erb'),
    notify  => $config_notify,
    require => File[$config_dir],
  }
}