diff --git a/data/common/kafka.yaml b/data/common/kafka.yaml --- a/data/common/kafka.yaml +++ b/data/common/kafka.yaml @@ -68,6 +68,8 @@ public_tls_port: 9093 internal_tls_port: 9094 public_listener_network: 128.93.166.0/26 + # to label the prometheus exporter metrics + environment: production rocquencourt_staging: zookeeper::chroot: '/kafka/softwareheritage' zookeeper::servers: @@ -89,5 +91,7 @@ cluster_config_overrides: offsets.topic.replication.factor: 1 # this is mandatory with only one node public_listener_network: "%{alias('kafka::cluster::public_network')}" + # to label the prometheus exporter metrics + environment: staging diff --git a/site-modules/profile/manifests/kafka/prometheus_consumer_group_exporter.pp b/site-modules/profile/manifests/kafka/prometheus_consumer_group_exporter.pp --- a/site-modules/profile/manifests/kafka/prometheus_consumer_group_exporter.pp +++ b/site-modules/profile/manifests/kafka/prometheus_consumer_group_exporter.pp @@ -26,8 +26,9 @@ $defaults_file = "${defaults_dir}/${cluster}" $service = "${pkg}@${cluster}" - $bootstrap_servers = $kafka_clusters[$cluster]["brokers"].keys.sort.join(',') + $bootstrap_servers = $kafka_clusters[$cluster]['brokers'].keys.sort.join(',') $port = $base_port + $index + $environment = $kafka_clusters[$cluster]['environment'] file {$defaults_file: ensure => present, @@ -39,8 +40,8 @@ } service {$service: - ensure => 'running', - enable => true, + ensure => 'running', + enable => true, require => [ File[$defaults_file], Package[$pkg], @@ -52,7 +53,8 @@ job => 'kafka-consumer-group', target => $target, labels => { - cluster => $cluster, + cluster => $cluster, + environment => $environment } } }