add log

server/node.go

@@ -206,6 +206,7 @@ func (n *Node) attachKafkaConsumer(ctx context.Context, taskCh chan *odysseus.Ta
 			}
 			// check if context was cancelled, signaling that the consumer should stop
 			if ctx.Err() != nil {
+				log.WithError(ctx.Err()).Error("consumer kafka context was cancelled")
 				return
 			}
 			consumer.ready = make(chan bool)