removes sentitnel error

gojekfarm · Apr 4, 2024 · 37f9b68 · 37f9b68
1 parent f4aca66
commit 37f9b68
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/kafka/errors.go b/kafka/errors.go
diff --git a/kafka/kafkahelper.go b/kafka/kafkahelper.go
@@ -1,6 +1,7 @@
 package kafka
 
 import (
+	"fmt"
 	"github.com/confluentinc/confluent-kafka-go/v2/kafka"
 )
 
@@ -20,7 +21,7 @@ func createConsumer(consumerConfig *kafka.ConfigMap, topics []string) confluentC
 // offsets are stored in memory and are later flushed by the auto-commit timer
 func storeOffsets(consumer confluentConsumer, partition kafka.TopicPartition) error {
 	if partition.Error != nil {
-		return ErrPart
+		return fmt.Errorf("error storing offsets:%w", partition.Error)
 	}
 	offsets := []kafka.TopicPartition{partition}
 	offsets[0].Offset++