Add cancellation check in consumer to prevent further scheduling actions

Author: dpiyumal2319

internal/kafka/consumer.go

@@ -124,6 +124,11 @@ func (c *Consumer) processSessionChange(event models.DebeziumEvent) {
 			return
 		}
 
+		if after.Status == "CANCELLED" {
+			log.Printf("Session %s was cancelled. No further scheduling actions will be taken.", after.ID)
+			return
+		}
+
 		// Check if on-sale time changed
 		if after.SalesStartTime != before.SalesStartTime {
 			onSaleTime := scheduler.MicrosecondsToTime(after.SalesStartTime)