108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
# File 'manifests/producer.pp', line 108
class kafka::producer (
Optional[String[1]] $input,
String[1] $kafka_version = $kafka::params::kafka_version,
String[1] $scala_version = $kafka::params::scala_version,
Stdlib::Absolutepath $install_dir = $kafka::params::install_dir,
Stdlib::HTTPUrl $mirror_url = $kafka::params::mirror_url,
Boolean $manage_java = $kafka::params::manage_java,
Stdlib::Absolutepath $package_dir = $kafka::params::package_dir,
Optional[String[1]] $package_name = $kafka::params::package_name,
String[1] $package_ensure = $kafka::params::package_ensure,
String[1] $user_name = $kafka::params::user_name,
Stdlib::Absolutepath $user_shell = $kafka::params::user_shell,
String[1] $group_name = $kafka::params::group_name,
Optional[Integer] $user_id = $kafka::params::user_id,
Optional[Integer] $group_id = $kafka::params::group_id,
Boolean $manage_user = $kafka::params::manage_user,
Boolean $manage_group = $kafka::params::manage_group,
Stdlib::Filemode $config_mode = $kafka::params::config_mode,
Stdlib::Absolutepath $config_dir = $kafka::params::config_dir,
Stdlib::Absolutepath $log_dir = $kafka::params::log_dir,
Stdlib::Absolutepath $bin_dir = $kafka::params::bin_dir,
String[1] $service_name = 'kafka-producer',
Boolean $manage_service = $kafka::params::manage_service,
Enum['running', 'stopped'] $service_ensure = $kafka::params::service_ensure,
Boolean $service_restart = $kafka::params::service_restart,
Array[String[1]] $service_requires = $kafka::params::service_requires,
Optional[String[1]] $limit_nofile = $kafka::params::limit_nofile,
Optional[String[1]] $limit_core = $kafka::params::limit_core,
Hash $env = {},
Hash[String[1], Any] $config = {},
Hash[String[1],String[1]] $service_config = {},
String[1] $jmx_opts = $kafka::params::producer_jmx_opts,
String[1] $log4j_opts = $kafka::params::producer_log4j_opts,
) inherits kafka::params {
class { 'kafka::producer::install': }
-> class { 'kafka::producer::config': }
-> class { 'kafka::producer::service': }
-> Class['kafka::producer']
}
|