small fix

kneu-messenger-pigeon · May 30, 2024 · c19022d · c19022d
1 parent 2740d3a
commit c19022d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/KafkaConsumerProcessor.go b/KafkaConsumerProcessor.go
@@ -3,6 +3,7 @@ package framework
 import (
 	"context"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"github.com/kneu-messenger-pigeon/events"
 	"github.com/segmentio/kafka-go"
@@ -71,7 +72,7 @@ func (processor *KafkaConsumerProcessor) Execute(ctx context.Context, wg *sync.W
 			}
 		}
 
-		if err != nil && err != context.Canceled {
+		if err != nil && !errors.Is(err, context.Canceled) {
 			_, _ = fmt.Fprintf(processor.out, "%T error: %v \n", processor.handler, err)
 		}
 	}