Commit d120ce74 authored by Waleed Akbar's avatar Waleed Akbar
Browse files

Promtheus exporter is sucessfully working.

parent f766e512

src/kpi_manager/service/KpiWriter.py

+2 −2
Original line number Diff line number Diff line
@@ -40,8 +40,6 @@ class KpiWriter: 


    @staticmethod

    def kpi_writer():

        # Start up the server to expose the metrics at port number mention below.

        start_http_server(8101)

        KpiWriter.create_prom_metrics_name()

        threading.Thread(target=KpiWriter.kafka_listener, args=()).start()
@@ -50,6 +48,8 @@ class KpiWriter: 
        """

        listener for events on Kafka topic.

        """

        # Start up the server to expose the metrics at port number mention below.

        start_http_server(8101, registry=KAFKA_REGISTERY)

        kafka_consumer = KafkaConsumer(CONSUMER_CONFIG)

        kafka_consumer.subscribe([KAFKA_TOPICS['labeled']])

        while True: