Merge pull request #52 from Trendyol/fix/duplicate-message-produce-issue

fix: duplicate produce in otel producer
Trendyol · Oct 6, 2023 · a319551 · a319551
2 parents 4805d9e + bc44651
commit a319551
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/otel_producer.go b/otel_producer.go
@@ -48,6 +48,7 @@ func (o *otelProducer) WriteMessages(ctx context.Context, messages ...segmentio.
 		if err := o.w.WriteMessage(ctx, messages[0]); err != nil {
 			return fmt.Errorf("error during producing %w", err)
 		}
+		return nil
 	}
 
 	if err := o.w.WriteMessages(ctx, messages); err != nil {