5
6
7
8
9
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
41
42
43
44
45
46
47
48
49
50
51
52
53
|
# File 'manifests/service.pp', line 5
class kafka_connect::service {
assert_private()
if ($kafka_connect::install_source == 'package' and
$kafka_connect::service_ensure == 'running' and $kafka_connect::package_ensure =~ /^(absent|purged)$/) {
warning("Ignoring service_ensure 'running' value since package_ensure is set to ${kafka_connect::package_ensure}")
$_service_ensure = 'stopped'
} else {
$_service_ensure = $kafka_connect::service_ensure
}
if ($kafka_connect::install_source == 'package' and
$kafka_connect::service_enable == true and $kafka_connect::package_ensure =~ /^(absent|purged)$/) {
warning("Ignoring service_enable true value since package_ensure is set to ${kafka_connect::package_ensure}")
$_service_enable = undef
} else {
$_service_enable = $kafka_connect::service_enable
}
if $kafka_connect::run_local_kafka_broker_and_zk {
if $kafka_connect::service_name =~ /^confluent-.*$/ {
$service_prefix = 'confluent-'
} else {
$service_prefix = ''
}
service { ["${service_prefix}zookeeper", "${service_prefix}kafka"]:
ensure => $_service_ensure,
enable => $_service_enable,
provider => $kafka_connect::service_provider,
before => Service[$kafka_connect::service_name],
}
}
service { $kafka_connect::service_name :
ensure => $_service_ensure,
enable => $_service_enable,
provider => $kafka_connect::service_provider,
}
exec { 'wait_30s_for_service_start':
command => 'sleep 30',
refreshonly => true,
path => ['/bin','/usr/bin','/usr/local/bin'],
subscribe => Service[$kafka_connect::service_name],
}
}
|