Changeset View
Changeset View
Standalone View
Standalone View
site-modules/profile/manifests/kafka/broker.pp
Show First 20 Lines • Show All 47 Lines • ▼ Show 20 Lines | $cluster_superusers = join( | ||||
pick_default($kafka_cluster_config['superusers'], []), | pick_default($kafka_cluster_config['superusers'], []), | ||||
';' | ';' | ||||
) | ) | ||||
$heap_opts = $kafka_cluster_config['broker::heap_opts'] | $heap_opts = $kafka_cluster_config['broker::heap_opts'] | ||||
$kafka_logdirs = lookup('kafka::logdirs', Array) | $kafka_logdirs = lookup('kafka::logdirs', Array) | ||||
$kafka_logdirs.each |$logdir| { | $kafka_logdirs.each |$logdir| { | ||||
file {$logdir: | exec {"create ${logdir}": | ||||
creates => $logdir, | |||||
command => "mkdir -p ${logdir}", | |||||
path => ['/bin', '/usr/bin', '/sbin', '/usr/sbin'], | |||||
} -> file {$logdir: | |||||
ensure => directory, | ensure => directory, | ||||
owner => 'kafka', | owner => 'kafka', | ||||
group => 'kafka', | group => 'kafka', | ||||
mode => '0750', | mode => '0750', | ||||
} -> Service['kafka'] | } | ||||
} | } | ||||
$do_tls = $kafka_cluster_config['tls'] | $do_tls = $kafka_cluster_config['tls'] | ||||
if $do_tls { | if $do_tls { | ||||
include ::profile::letsencrypt::host_cert | include ::profile::letsencrypt::host_cert | ||||
$cert_paths = ::profile::letsencrypt::certificate_paths($trusted['certname']) | $cert_paths = ::profile::letsencrypt::certificate_paths($trusted['certname']) | ||||
# $cert_paths['cert'], $cert_paths['chain'], $cert_paths['privkey'] | # $cert_paths['cert'], $cert_paths['chain'], $cert_paths['privkey'] | ||||
▲ Show 20 Lines • Show All 156 Lines • Show Last 20 Lines |