Merge branch 'master' of github.com:InternetHealthReport/kafka-toolbox

Author: romain-fontugne

psql/consumers/CountryHegemony.py

@@ -32,7 +32,7 @@ def __init__(self, af, host="localhost", dbname="ihr"):
 
         self.consumer = Consumer({
             'bootstrap.servers': KAFKA_HOST,
-            'group.id': 'ihr_hegemony_countries_psql_sink_ipv{}'.format(self.af),
+            'group.id': 'ihr_hegemony_countries_psql_sink00_ipv{}'.format(self.af),
             'auto.offset.reset': 'earliest',
             })
 

psql/consumers/anomalyAtlasdelay.conf

@@ -20,7 +20,7 @@ default_values={}
 fields=ts,deviation,startpoint,endpoint
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_raclette_diffrtt_anomaly_sink
+consumer_group=ihr_raclette_diffrtt_anomaly_sink00
 
 
 # Configuration for python logger:

psql/consumers/anomalyHegemony.conf

@@ -20,7 +20,7 @@ fields=timestamp,deviation,af,asn,scope
 default_values={'af':4}
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_hegemony_anomaly_ipv4_sink
+consumer_group=ihr_hegemony_anomaly_ipv4_sink00
 
 
 # Configuration for python logger:

psql/consumers/anomalyHegemony_v6.conf

@@ -20,7 +20,7 @@ fields=timestamp,deviation,af,asn,scope
 default_values={'af':6}
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_hegemony_anomaly_ipv6_sink
+consumer_group=ihr_hegemony_anomaly_ipv6_sink00
 
 
 # Configuration for python logger:

psql/consumers/disco.py

@@ -25,15 +25,15 @@ def __init__(self, host="localhost", dbname="ihr", suffix=''):
 
         self.consumer_bursts = Consumer({
             'bootstrap.servers': KAFKA_HOST,
-            'group.id': 'ihr_disco_bursts_psql_sink0',
+            'group.id': 'ihr_disco_bursts_psql_sink00',
             'auto.offset.reset': 'earliest',
             'enable.auto.commit': 'false',
             })
         self.consumer_bursts.subscribe(['ihr_disco_bursts{}'.format(suffix)])
 
         self.consumer_reconnect = Consumer({
             'bootstrap.servers': KAFKA_HOST,
-            'group.id': 'ihr_disco_reconnect_psql_sink0',
+            'group.id': 'ihr_disco_reconnect_psql_sink00',
             'auto.offset.reset': 'earliest',
             'enable.auto.commit': 'false',
             'enable.auto.offset.store': 'false',

psql/consumers/metis_atlas_deployment_v4_as_path_length.conf

@@ -20,7 +20,7 @@ default_values={"af":4, "metric": "as_path_length"}
 fields=timestamp,metric,rank,af,mean,asn,num_samples
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_metis_v4_as_path_length_sink1
+consumer_group=ihr_metis_v4_as_path_length_sink00
 
 
 # Configuration for python logger:

psql/consumers/metis_atlas_deployment_v4_ip_hops.conf

@@ -20,7 +20,7 @@ default_values={"af":4, "metric": "ip_hops"}
 fields=timestamp,metric,rank,af,mean,asn,num_samples
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_metis_v4_ip_hops_sink0
+consumer_group=ihr_metis_v4_ip_hops_sink00
 
 
 # Configuration for python logger:

psql/consumers/metis_atlas_deployment_v4_rtt.conf

@@ -20,7 +20,7 @@ default_values={"af":4, "metric": "rtt"}
 fields=timestamp,metric,rank,af,mean,asn,num_samples
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_metis_v4_rtt_sink0
+consumer_group=ihr_metis_v4_rtt_sink00
 
 
 # Configuration for python logger:

psql/consumers/metis_atlas_deployment_v6_as_path_length.conf

@@ -20,7 +20,7 @@ default_values={"af":6, "metric": "as_path_length"}
 fields=timestamp,metric,rank,af,mean,asn,num_samples
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_metis_v6_as_path_length_sink0
+consumer_group=ihr_metis_v6_as_path_length_sink00
 
 
 # Configuration for python logger:

psql/consumers/metis_atlas_deployment_v6_ip_hops.conf

@@ -20,7 +20,7 @@ default_values={"af":6, "metric": "ip_hops"}
 fields=timestamp,metric,rank,af,mean,asn,num_samples
 
 # Kafka consumer group ID. Used for parallel processing and offset management.
-consumer_group=ihr_metis_v6_ip_hops_sink0
+consumer_group=ihr_metis_v6_ip_hops_sink00
 
 
 # Configuration for python logger: