Puppet Class: kafka::producer::config

Defined in:
manifests/producer/config.pp

Overview

Class: kafka::producer::config

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

Parameters:

  • config_dir (Stdlib::Absolutepath) (defaults to: $kafka::producer::config_dir)
  • service_name (String) (defaults to: $kafka::producer::service_name)
  • service_install (Boolean) (defaults to: $kafka::producer::service_install)
  • service_restart (Boolean) (defaults to: $kafka::producer::service_restart)
  • config (Hash) (defaults to: $kafka::producer::config)
  • config_mode (Stdlib::Filemode) (defaults to: $kafka::producer::config_mode)
  • group (String) (defaults to: $kafka::producer::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
 
# File 'manifests/producer/config.pp', line 10

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

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

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