Page MenuHomeSoftware Heritage
Files F9697034

No OneTemporary
Actions

View Options

diff --git a/manifests/broker/config.pp b/manifests/broker/config.pp
index d9986a7..f736a8e 100644
--- a/manifests/broker/config.pp
+++ b/manifests/broker/config.pp
@@ -1,50 +1,50 @@
# Author:: Liam Bennett (mailto:lbennett@opentable.com)
# Copyright:: Copyright (c) 2013 OpenTable Inc
# License:: MIT
# == Class: kafka::broker::config
#
# This private class is meant to be called from `kafka::broker`.
# It manages the broker config files
#
class kafka::broker::config(
$config = $kafka::broker::config,
$config_defaults = $kafka::broker::config_defaults,
$install_dir = $kafka::broker::install_dir,
$service_restart = $kafka::broker::service_restart,
$service_install = $kafka::broker::service_install,
$config_dir = $kafka::broker::config_dir,
) {
if $caller_module_name != $module_name {
fail("Use of private class ${name} by ${caller_module_name}")
}
$version = $kafka::version
if $version and versioncmp($version, '0.9.0.0') < 0 {
if $config['broker.id'] == '-1' {
fail('[Broker] You need to specify a value for broker.id')
}
}
$server_config = deep_merge($config_defaults, $config)
if $service_install {
$config_notify = $service_restart ? {
true => Service['kafka'],
false => undef
}
} else {
$config_notify = undef
}
file { "${config_dir}/server.properties":
ensure => present,
- owner => 'kafka',
- group => 'kafka',
+ owner => 'root',
+ group => 'root',
mode => '0644',
content => template('kafka/server.properties.erb'),
notify => $config_notify,
require => File[$config_dir],
}
}
diff --git a/manifests/consumer/config.pp b/manifests/consumer/config.pp
index f627aa8..a963155 100644
--- a/manifests/consumer/config.pp
+++ b/manifests/consumer/config.pp
@@ -1,34 +1,34 @@
# Author:: Liam Bennett (mailto:lbennett@opentable.com)
# Copyright:: Copyright (c) 2013 OpenTable Inc
# License:: MIT
# == Class: kafka::consumer::config
#
# This private class is meant to be called from `kafka::consumer`.
# It manages the consumer config files
#
define kafka::consumer::config(
$config = $kafka::consumer::config,
$config_defaults = $kafka::consumer::config_defaults,
$service_name = 'kafka-consumer',
$service_restart = $kafka::consumer::service_restart,
$config_dir = $kafka::consumer::config_dir,
) {
$consumer_config = deep_merge($config_defaults, $config)
$config_notify = $service_restart ? {
true => Service[$service_name],
default => undef
}
file { "${config_dir}/${name}.properties":
ensure => present,
- owner => 'kafka',
- group => 'kafka',
+ owner => 'root',
+ group => 'root',
mode => '0644',
content => template('kafka/consumer.properties.erb'),
notify => $config_notify,
require => File[$config_dir],
}
}
diff --git a/manifests/producer/config.pp b/manifests/producer/config.pp
index 0f80503..5a4c2b7 100644
--- a/manifests/producer/config.pp
+++ b/manifests/producer/config.pp
@@ -1,34 +1,34 @@
# Author:: Liam Bennett (mailto:lbennett@opentable.com)
# Copyright:: Copyright (c) 2013 OpenTable Inc
# License:: MIT
# == Class: kafka::producer::config
#
# This private class is meant to be called from `kafka::producer`.
# It manages the producer config files
#
class kafka::producer::config(
$config = $kafka::producer::config,
$config_defaults = $kafka::producer::config_defaults,
$service_name = 'kafka-producer',
$service_restart = $kafka::producer::service_restart,
$config_dir = $kafka::producer::config_dir,
) {
$producer_config = deep_merge($config_defaults, $config)
$config_notify = $service_restart ? {
true => Service[$service_name],
default => undef
}
file { "${config_dir}/producer.properties":
ensure => present,
- owner => 'kafka',
- group => 'kafka',
+ owner => 'root',
+ group => 'root',
mode => '0644',
content => template('kafka/producer.properties.erb'),
notify => $config_notify,
require => File[$config_dir],
}
}

File Metadata

Mime Type
text/x-diff
Expires
Mon, Aug 18, 10:33 PM (1 w, 1 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3326396

Event Timeline

About · Developer information · Legal