Merge pull request #76 from MarkJoyMa/fix/kq_sync_producer

kevwan · web-flow · commit 7e3925499dca · 2024-09-12T16:45:51.000+08:00
diff --git a/kq/pusher.go b/kq/pusher.go
@@ -67,6 +67,7 @@ func NewPusher(addrs []string, topic string, opts ...PushOption) *Pusher {
 
 	// if syncPush is true, return the pusher directly
 	if options.syncPush {
+		producer.BatchSize = 1
 		return pusher
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,7 @@ func NewPusher(addrs []string, topic string, opts ...PushOption) *Pusher {`
`67`	`67`
`68`	`68`	`// if syncPush is true, return the pusher directly`
`69`	`69`	`if options.syncPush {`
	`70`	`+ producer.BatchSize = 1`
`70`	`71`	`return pusher`
`71`	`72`	`}`
`72`	`73`