feat(kafka): try with equality match

SigNoz · Oct 8, 2024 · 7d29ef2 · 7d29ef2
1 parent 8977dc8
commit 7d29ef2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/receiver/signozkafkareceiver/kafka_receiver.go b/receiver/signozkafkareceiver/kafka_receiver.go
@@ -494,7 +494,7 @@ type baseConsumerGroupHandler struct {
 func (b *baseConsumerGroupHandler) WithMemoryLimiter(ctx context.Context, claim sarama.ConsumerGroupClaim, consume func() error) error {
 	// Execute f() immediately
 	err := consume()
-	if err == nil || !errors.Is(err, errHighMemoryUsage) {
+	if err == nil || !(err.Error() == errHighMemoryUsage.Error()) {
 		return err
 	}
 
@@ -514,7 +514,7 @@ func (b *baseConsumerGroupHandler) WithMemoryLimiter(ctx context.Context, claim
 				b.resumePartition <- claim.Partition()
 				return nil
 			}
-			if !errors.Is(err, errHighMemoryUsage) {
+			if !(err.Error() == errHighMemoryUsage.Error()) {
 				b.resumePartition <- claim.Partition()
 				return err
 			}