fix: duplicate produce in otel producer

Trendyol · Oct 6, 2023 · bc44651 · bc44651
1 parent 4805d9e
commit bc44651
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 {