Merge pull request #1 from DerBlum/patch-1

Fix MaxWait only configuration
Deeptiman · Jan 25, 2022 · e7a1457 · e7a1457
2 parents 450e3a5 + 7e509ac
commit e7a1457
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/producer.go b/producer.go
@@ -85,7 +85,7 @@ func (p *BatchProducer) WatchProducer() {
 		case <-time.After(p.MaxWait):
 			p.Log.Infoln("MaxWait", "Items=", len(items))
 			if len(items) == 0 {
-				return
+				continue
 			}
 
 			items = p.releaseBatch(items)
@@ -132,4 +132,4 @@ func (p *BatchProducer) createBatchNo() {
 // getBatchNo will get the current BatchNo from the atomic variable.
 func (p *BatchProducer) getBatchNo() int32 {
 	return atomic.LoadInt32(&p.BatchNo)
-}
+}