added log to check the count of events

portality/events/kafka_consumer.py

@@ -11,13 +11,17 @@
 app = faust.App('events', broker=broker, value_serializer='json')
 topic = app.topic(topic_name)
 
+event_counter = 0
+
 
 @app.agent(topic)
 async def handle_event(stream):
+    global event_counter
     with doajapp.test_request_context("/"):
         svc = DOAJ.eventsService()
         async for event in stream:
-            pass
+            event_counter += 1
+            doajapp.logger.info(f"Kafka event count {event_counter}")
             # TODO uncomment the following line once the Event model is fixed to Kafka
             # svc.consume(Event(raw=json.loads(event)))