diff --git a/receiver/signozkafkareceiver/kafka_receiver.go b/receiver/signozkafkareceiver/kafka_receiver.go
index 0eaa1591..1f0098d1 100644
--- 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
 			}