Removed unnecessary flush in sync Send() operation (#230)

apache · Apr 20, 2020 · 23d4808 · 23d4808
1 parent a575681
commit 23d4808
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -357,12 +357,6 @@ func (p *partitionProducer) Send(ctx context.Context, msg *ProducerMessage) (Mes
 		wg.Done()
 	}, true)
 
-	// When sending synchronously we flush immediately to avoid
-	// the increased latency and reduced throughput of batching
-	if err = p.Flush(); err != nil {
-		return nil, err
-	}
-
 	wg.Wait()
 	return msgID, err
 }