Merge pull request #57 from openedx/diana/monitoring-consumption

feat: Add monitoring to consumption tasks.

CHANGELOG.rst

@@ -16,6 +16,14 @@ Unreleased
 
 *
 
+[1.1.0] - 2022-10-06
+********************
+
+Changed
+=======
+
+* Added monitoring for consumption tasks.
+
 [1.0.0] - 2022-10-03
 ********************
 

edx_event_bus_kafka/__init__.py

@@ -9,4 +9,4 @@
 from edx_event_bus_kafka.internal.consumer import KafkaEventConsumer
 from edx_event_bus_kafka.internal.producer import KafkaEventProducer, get_producer
 
-__version__ = '1.0.0'
+__version__ = '1.1.0'

edx_event_bus_kafka/internal/consumer.py

@@ -7,6 +7,7 @@
 from django.conf import settings
 from django.core.management.base import BaseCommand
 from django.dispatch import receiver
+from edx_django_utils.monitoring import background_task
 from edx_toggles.toggles import SettingToggle
 from openedx_events.event_bus.avro.deserializer import AvroSignalDeserializer
 from openedx_events.learning.data import UserData
@@ -114,6 +115,7 @@ def consume_indefinitely(self):
             self.consumer.close()
             logger.info("Committing final offsets")
 
+    @background_task()
     def process_single_message(self, msg):
         """
         Emit signal with message data