set up some basic manifests for service control and package installs

manifests/init.pp

@@ -1,28 +1,38 @@
-class confluent (
+class confluent (  
   $version        = '3.0',
+  $scala_version  = '2.11',
   $kafka          = false,
-  $kafkastreams   = false,
   $zookeeper      = false,
   $schemaregistry = false,
   $restservice    = false,
 ) {
 
-  if ! ($kafka or $kafkastreams or $zookeeper or $schemaregistry or $restservice) {
+  if ! ($kafka or $zookeeper or $schemaregistry or $restservice) {
     fail('You must choose to install at least one component')
   }
 
-  if $kafka {
-    include ::confluent::kafka
-  }
+  # Kafka and zookeeper are in same package
 
-  if $kafkastreams {
-    include ::confluent::kafkastreams
-  }
+  if ($kafka or $zookeeper) {
+
+    $packages = [ "confluent-kafka-${::confluent::scala_version}" ]
+
+    package { $packages:
+      ensure => installed,
+    }
+
+    if $kafka {
+      include ::confluent::kafka
+    }
+
+    if $zookeeper {
+      include ::confluent::zookeeper
+    }
 
-  if $zookeeper {
-    include ::confluent::zookeeper
   }
 
+  #Separate components
+
   if $schemaregistry {
     include ::confluent::schemaregistry
   }

manifests/kafka.pp

@@ -1 +1,7 @@
-class confluent::kafka { }
+class confluent::kafka { 
+
+  class { '::confluent::kafka::config': } ->
+  class { '::confluent::kafka::service': }
+
+
+}

manifests/kafka/service.pp

@@ -1 +1,14 @@
-class confluent::kafka::service { }
+class confluent::kafka::service {
+
+  file { '/etc/init.d/kafka':
+    ensure => file,
+    mode   => '0755',
+  }
+
+  service { 'kafka':
+    ensure  => running,
+    enable  => true,
+    require => File['/etc/init.d/kafka'],
+  }
+
+}

manifests/restservice/install.pp

@@ -1 +1,7 @@
-class confluent::restservice::install { }
+class confluent::restservice::install {
+
+  package { 'confluent-kafka-rest':
+    ensure => installed,
+  }
+
+}

manifests/restservice/service.pp

@@ -1 +1,14 @@
-class confluent::restservice::service { }
+class confluent::restservice::service {
+
+  file { '/etc/init.d/kafka-restservice':
+    ensure => file,
+    mode   => '0755',
+  }
+
+  service { 'kafka-restservice':
+    ensure  => running,
+    enable  => true,
+    require => File['/etc/init.d/kafka-restservice'],
+  }
+
+}

manifests/schemaregistry/install.pp

@@ -1 +1,7 @@
-class confluent::schemaregistry::install { }
+class confluent::schemaregistry::install {
+
+  package { 'confluent-schema-registry':
+    ensure => installed,
+  }
+
+}

manifests/schemaregistry/service.pp

@@ -1 +1,14 @@
-class confluent::schemaregistry::service { }
+class confluent::schemaregistry::service {
+
+  file { '/etc/init.d/kafka-schemaregistry':
+    ensure => file,
+    mode   => '0755',
+  }
+
+  service { 'kafka-schemaregistry':
+    ensure  => running,
+    enable  => true,
+    require => File['/etc/init.d/kafka-schemaregistry'],
+  }
+
+}

manifests/zookeeper.pp

@@ -1 +1,6 @@
-class confluent::zookeeper { }
+class confluent::zookeeper { 
+
+  class { '::confluent::zookeeper::config': } ->
+  class { '::confluent::zookeeper::service': }
+
+}

manifests/zookeeper/service.pp

@@ -1 +1,14 @@
-class confluent::zookeeper::service { }
+class confluent::zookeeper::service { 
+
+  file { '/etc/init.d/zookeeper':
+    ensure => file,
+    mode   => '0755',
+  }
+
+  service { 'zoookeeper':
+    ensure  => running,
+    enable  => true,
+    require => File['/etc/init.d/zookeeper'],
+  }
+
+}