Drop support for non systemd OS

REFERENCE.md

@@ -502,7 +502,7 @@ Default value: `'kafka'`
 
 Data type: `Boolean`
 
-Install the init.d or systemd service.
+Install the systemd service.
 
 Default value: `$kafka::params::manage_service`
 
@@ -862,7 +862,7 @@ Default value: `'kafka-consumer'`
 
 Data type: `Boolean`
 
-Install the init.d or systemd service.
+Install the systemd service.
 
 Default value: `$kafka::params::manage_service`
 
@@ -1306,7 +1306,7 @@ Default value: `'kafka-mirror'`
 
 Data type: `Boolean`
 
-Install the init.d or systemd service.
+Install the systemd service.
 
 Default value: `$kafka::params::manage_service`
 
@@ -1658,7 +1658,7 @@ Default value: `'kafka-producer'`
 
 Data type: `Boolean`
 
-Install the init.d or systemd service.
+Install systemd service.
 
 Default value: `$kafka::params::manage_service`
 

manifests/broker.pp

@@ -70,7 +70,7 @@
 #   Set the name of the service.
 #
 # @param manage_service
-#   Install the init.d or systemd service.
+#   Install the systemd service.
 #
 # @param service_ensure
 #   Set the ensure state of the service.

manifests/broker/service.pp

@@ -36,31 +36,14 @@
     }
     $environment = deep_merge($env_defaults, $env)
 
-    if $facts['service_provider'] == 'systemd' {
-      include systemd
+    include systemd
 
-      file { "/etc/systemd/system/${service_name}.service":
-        ensure  => file,
-        mode    => '0644',
-        content => template('kafka/unit.erb'),
-      }
-
-      file { "/etc/init.d/${service_name}":
-        ensure => absent,
-      }
-
-      File["/etc/systemd/system/${service_name}.service"]
-      ~> Service[$service_name]
-    } else {
-      file { "/etc/init.d/${service_name}":
-        ensure  => file,
-        mode    => '0755',
-        content => template('kafka/init.erb'),
-        before  => Service[$service_name],
-      }
+    file { "/etc/systemd/system/${service_name}.service":
+      ensure  => file,
+      mode    => '0644',
+      content => template('kafka/unit.erb'),
     }
-
-    service { $service_name:
+    ~> service { $service_name:
       ensure     => $service_ensure,
       enable     => true,
       hasstatus  => true,

manifests/consumer.pp

@@ -70,7 +70,7 @@
 #   Set the name of the service.
 #
 # @param manage_service
-#   Install the init.d or systemd service.
+#   Install the systemd service.
 #
 # @param service_ensure
 #   Set the ensure state of the service.

manifests/consumer/service.pp

@@ -36,31 +36,14 @@
     }
     $environment = deep_merge($env_defaults, $env)
 
-    if $facts['service_provider'] == 'systemd' {
-      include systemd
+    include systemd
 
-      file { "/etc/systemd/system/${service_name}.service":
-        ensure  => file,
-        mode    => '0644',
-        content => template('kafka/unit.erb'),
-      }
-
-      file { "/etc/init.d/${service_name}":
-        ensure => absent,
-      }
-
-      File["/etc/systemd/system/${service_name}.service"]
-      ~> Service[$service_name]
-    } else {
-      file { "/etc/init.d/${service_name}":
-        ensure  => file,
-        mode    => '0755',
-        content => template('kafka/init.erb'),
-        before  => Service[$service_name],
-      }
+    file { "/etc/systemd/system/${service_name}.service":
+      ensure  => file,
+      mode    => '0644',
+      content => template('kafka/unit.erb'),
     }
-
-    service { $service_name:
+    ~> service { $service_name:
       ensure     => $service_ensure,
       enable     => true,
       hasstatus  => true,

manifests/mirror.pp

@@ -76,7 +76,7 @@
 #   Set the name of the service.
 #
 # @param manage_service
-#   Install the init.d or systemd service.
+#   Install the systemd service.
 #
 # @param service_ensure
 #   Set the ensure state of the service.

manifests/mirror/service.pp

@@ -33,31 +33,14 @@
     }
     $environment = deep_merge($env_defaults, $env)
 
-    if $facts['service_provider'] == 'systemd' {
-      include systemd
+    include systemd
 
-      file { "/etc/systemd/system/${service_name}.service":
-        ensure  => file,
-        mode    => '0644',
-        content => template('kafka/unit.erb'),
-      }
-
-      file { "/etc/init.d/${service_name}":
-        ensure => absent,
-      }
-
-      File["/etc/systemd/system/${service_name}.service"]
-      ~> Service[$service_name]
-    } else {
-      file { "/etc/init.d/${service_name}":
-        ensure  => file,
-        mode    => '0755',
-        content => template('kafka/init.erb'),
-        before  => Service[$service_name],
-      }
+    file { "/etc/systemd/system/${service_name}.service":
+      ensure  => file,
+      mode    => '0644',
+      content => template('kafka/unit.erb'),
     }
-
-    service { $service_name:
+    ~> service { $service_name:
       ensure     => $service_ensure,
       enable     => true,
       hasstatus  => true,

manifests/producer.pp

@@ -73,7 +73,7 @@
 #   Set the name of the service.
 #
 # @param manage_service
-#   Install the init.d or systemd service.
+#   Install systemd service.
 #
 # @param service_ensure
 #   Set the ensure state of the service.

manifests/producer/service.pp

@@ -37,16 +37,7 @@
     }
     $environment = deep_merge($env_defaults, $env)
 
-    if $facts['service_provider'] == 'systemd' {
-      fail('Console Producer is not supported on systemd, because the stdin of the process cannot be redirected')
-    } else {
-      file { "/etc/init.d/${service_name}":
-        ensure  => file,
-        mode    => '0755',
-        content => template('kafka/init.erb'),
-        before  => Service[$service_name],
-      }
-    }
+    fail('Console Producer is not supported on systemd, because the stdin of the process cannot be redirected')
 
     service { $service_name:
       ensure     => $service_ensure,

spec/acceptance/broker_spec.rb

@@ -162,7 +162,7 @@ class { 'kafka::broker':
         apply_manifest(pp, catch_failures: true)
       end
 
-      describe file('/etc/systemd/system/kafka.service'), if: (fact('operatingsystemmajrelease') == '7' && fact('osfamily') == 'RedHat') do
+      describe file('/etc/systemd/system/kafka.service') do
         it { is_expected.to be_file }
         it { is_expected.to be_owned_by 'root' }
         it { is_expected.to be_grouped_into 'root' }
@@ -197,17 +197,7 @@ class { 'kafka::broker':
         apply_manifest(pp, catch_changes: true)
       end
 
-      describe file('/etc/init.d/kafka'), if: (fact('service_provider') == 'upstart' && fact('osfamily') == 'Debian') do
-        it { is_expected.to be_file }
-        it { is_expected.to be_owned_by 'root' }
-        it { is_expected.to be_grouped_into 'root' }
-        it { is_expected.to contain %r{^# Provides:\s+kafka$} }
-        it { is_expected.to contain 'export KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote"' }
-        it { is_expected.to contain 'export KAFKA_HEAP_OPTS="-Xmx512M -Xmx512M"' }
-        it { is_expected.to contain 'export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/tmp/log4j.properties"' }
-      end
-
-      describe file('/etc/systemd/system/kafka.service'), if: (fact('operatingsystemmajrelease') == '7' && fact('osfamily') == 'RedHat') do
+      describe file('/etc/systemd/system/kafka.service') do
         it { is_expected.to be_file }
         it { is_expected.to be_owned_by 'root' }
         it { is_expected.to be_grouped_into 'root' }

spec/acceptance/consumer_spec.rb

@@ -140,16 +140,7 @@ class { 'kafka::consumer':
         apply_manifest(pp, catch_failures: true)
       end
 
-      describe file('/etc/init.d/kafka-consumer'), if: (fact('service_provider') == 'upstart' && fact('osfamily') == 'Debian') do
-        it { is_expected.to be_file }
-        it { is_expected.to be_owned_by 'root' }
-        it { is_expected.to be_grouped_into 'root' }
-        it { is_expected.to contain %r{^# Provides:\s+kafka-consumer$} }
-        it { is_expected.to contain 'export KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.port=9993"' }
-        it { is_expected.to contain 'export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/opt/kafka/config/log4j.properties"' }
-      end
-
-      describe file('/etc/systemd/system/kafka-consumer.service'), if: (fact('operatingsystemmajrelease') == '7' && fact('osfamily') == 'RedHat') do
+      describe file('/etc/systemd/system/kafka-consumer.service') do
         it { is_expected.to be_file }
         it { is_expected.to be_owned_by 'root' }
         it { is_expected.to be_grouped_into 'root' }

spec/acceptance/mirror_spec.rb

@@ -220,16 +220,7 @@ class { 'kafka::mirror':
         apply_manifest(pp, catch_changes: true)
       end
 
-      describe file('/etc/init.d/kafka-mirror'), if: (fact('service_provider') == 'upstart' && fact('osfamily') == 'Debian') do
-        it { is_expected.to be_file }
-        it { is_expected.to be_owned_by 'root' }
-        it { is_expected.to be_grouped_into 'root' }
-        it { is_expected.to contain %r{^# Provides:\s+kafka-mirror$} }
-        it { is_expected.to contain 'export KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.port=9991"' }
-        it { is_expected.to contain 'export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/opt/kafka/config/log4j.properties"' }
-      end
-
-      describe file('/etc/systemd/system/kafka-mirror.service'), if: (fact('operatingsystemmajrelease') == '7' && fact('osfamily') == 'RedHat') do
+      describe file('/etc/systemd/system/kafka-mirror.service') do
         it { is_expected.to be_file }
         it { is_expected.to be_owned_by 'root' }
         it { is_expected.to be_grouped_into 'root' }

spec/classes/broker_spec.rb

@@ -52,41 +52,26 @@
         context 'manage_service false' do
           let(:params) { super().merge(manage_service: false) }
 
-          it { is_expected.not_to contain_file('/etc/init.d/kafka') }
           it { is_expected.not_to contain_file('/etc/systemd/system/kafka.service') }
           it { is_expected.not_to contain_service('kafka') }
         end
 
         context 'defaults' do
-          if os_facts['service_provider'] == 'systemd'
-            it { is_expected.to contain_file('/etc/init.d/kafka').with_ensure('absent') }
-            it { is_expected.not_to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitNOFILE=} }
-            it { is_expected.not_to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitCORE=} }
-          else
-            it { is_expected.to contain_file('/etc/init.d/kafka') }
-          end
-
+          it { is_expected.not_to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitNOFILE=} }
+          it { is_expected.not_to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitCORE=} }
           it { is_expected.to contain_service('kafka') }
         end
 
         context 'limit_nofile set' do
           let(:params) { super().merge(limit_nofile: '65536') }
 
-          if os_facts['service_provider'] == 'systemd'
-            it { is_expected.to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitNOFILE=65536$} }
-          else
-            it { is_expected.to contain_file('/etc/init.d/kafka').with_content %r{ulimit -n 65536$} }
-          end
+          it { is_expected.to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitNOFILE=65536$} }
         end
 
         context 'limit_core set' do
           let(:params) { super().merge(limit_core: 'infinity') }
 
-          if os_facts['service_provider'] == 'systemd'
-            it { is_expected.to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitCORE=infinity$} }
-          else
-            it { is_expected.to contain_file('/etc/init.d/kafka').with_content %r{ulimit -c infinity$} }
-          end
+          it { is_expected.to contain_file('/etc/systemd/system/kafka.service').with_content %r{^LimitCORE=infinity$} }
         end
 
         context 'service_requires set', if: os_facts['service_provider'] == 'systemd' do

spec/classes/consumer_spec.rb

@@ -51,12 +51,7 @@
 
       describe 'kafka::consumer::service' do
         context 'defaults' do
-          if os_facts['service_provider'] == 'systemd'
-            it { is_expected.to contain_file('/etc/systemd/system/kafka-consumer.service') }
-          else
-            it { is_expected.to contain_file('/etc/init.d/kafka-consumer') }
-          end
-
+          it { is_expected.to contain_file('/etc/systemd/system/kafka-consumer.service') }
           it { is_expected.to contain_service('kafka-consumer') }
         end
       end

spec/classes/mirror_spec.rb

@@ -48,14 +48,7 @@
 
       describe 'kafka::mirror::service' do
         context 'defaults' do
-          if os_facts['service_provider'] == 'systemd'
-            it { is_expected.to contain_file('/etc/init.d/kafka-mirror').with_ensure('absent') }
-            it { is_expected.to contain_file('/etc/systemd/system/kafka-mirror.service').with_content %r{/opt/kafka/config/(?=.*consumer)|(?=.*producer).propertie} }
-          else
-            it { is_expected.to contain_file('/etc/init.d/kafka-mirror') }
-            it { is_expected.to contain_file('/etc/init.d/kafka-mirror').with_content %r{/opt/kafka/config/(?=.*consumer)|(?=.*producer).properties} }
-          end
-
+          it { is_expected.to contain_file('/etc/systemd/system/kafka-mirror.service').with_content %r{/opt/kafka/config/(?=.*consumer)|(?=.*producer).propertie} }
           it { is_expected.to contain_service('kafka-mirror') }
         end
       end

spec/classes/producer_spec.rb

@@ -20,35 +20,7 @@
         }
       end
 
-      if os_facts['service_provider'] == 'systemd'
-        it { is_expected.to compile.and_raise_error(%r{Console Producer is not supported on systemd, because the stdin of the process cannot be redirected}) }
-      else
-        it { is_expected.to contain_class('kafka::producer::install').that_comes_before('Class[kafka::producer::config]') }
-        it { is_expected.to contain_class('kafka::producer::config').that_comes_before('Class[kafka::producer::service]') }
-        it { is_expected.to contain_class('kafka::producer::service').that_comes_before('Class[kafka::producer]') }
-        it { is_expected.to contain_class('kafka::producer') }
-
-        describe 'kafka::producer::install' do
-          context 'defaults' do
-            it { is_expected.to contain_class('kafka') }
-          end
-        end
-
-        describe 'kafka::producer::config' do
-          context 'defaults' do
-            it { is_expected.to contain_file('/opt/kafka/config/producer.properties') }
-          end
-        end
-
-        describe 'kafka::producer::service' do
-          context 'defaults' do
-            it { is_expected.to contain_file('/etc/init.d/kafka-producer') }
-            it { is_expected.to contain_service('kafka-producer') }
-          end
-        end
-
-        it_validates_parameter 'mirror_url'
-      end
+      it { is_expected.to compile.and_raise_error(%r{Console Producer is not supported on systemd, because the stdin of the process cannot be redirected}) }
     end
   end
 end