Puppet Class: kafka_connect::manage_connectors

Defined in:
manifests/manage_connectors.pp

Summary

Class to manage individual Kafka Connect connectors and connector secrets.

Overview



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'manifests/manage_connectors.pp', line 5

class kafka_connect::manage_connectors {
  assert_private()

  ensure_resource('file', $kafka_connect::connector_config_dir, { 'ensure' => 'directory' })

  $connectors_data = lookup(kafka_connect::connectors, Optional[Kafka_connect::Connectors], deep, undef)

  if $connectors_data != undef {
    class { 'kafka_connect::manage_connectors::connector':
      connectors_data => $connectors_data,
    }
  }

  $secrets_data = lookup(kafka_connect::secrets, Optional[Kafka_connect::Secrets], deep, undef)

  if $secrets_data != undef {
    class { 'kafka_connect::manage_connectors::secret':
      secrets_data => $secrets_data,
    }
  }
}