Skip to content
Snippets Groups Projects
  • Waleed Akbar's avatar
    c1ee28db
    Changes in Analytics · c1ee28db
    Waleed Akbar authored
    Backend:
    - Updated the `StartSparkStreamer` function call to send `Analyzer_uuid` as the key for messages produced on the Kafka topic.
    - Updated the `SparkStream` definition to receive the key and added the key to the `streamwriter` object.
    
    Frontend:
    - Integrated APScheduler to manage `StreamListener`.
    - Added `ResponseListener` to consume messages from the `analytics_response_topic` and process them.
    - Added APScheduler to manage StreamListener.
    - Added "ResponseListener" to consumer messages from analytics response_topic and process it.
    c1ee28db
    History
    Changes in Analytics
    Waleed Akbar authored
    Backend:
    - Updated the `StartSparkStreamer` function call to send `Analyzer_uuid` as the key for messages produced on the Kafka topic.
    - Updated the `SparkStream` definition to receive the key and added the key to the `streamwriter` object.
    
    Frontend:
    - Integrated APScheduler to manage `StreamListener`.
    - Added `ResponseListener` to consume messages from the `analytics_response_topic` and process them.
    - Added APScheduler to manage StreamListener.
    - Added "ResponseListener" to consumer messages from analytics response_topic and process it.
Code owners
Assign users and groups as approvers for specific file changes. Learn more.