reduce buffer size

Fu Wenhui · Fu Wenhui · commit 7a07094abab2 · 2020-11-24T20:29:09.000+08:00
diff --git a/replication/binlogstreamer.go b/replication/binlogstreamer.go
@@ -89,7 +89,7 @@ func (s *BinlogStreamer) closeWithError(err error) {
 func newBinlogStreamer() *BinlogStreamer {
 	s := new(BinlogStreamer)
 
-	s.ch = make(chan *BinlogEvent, 10240)
+	s.ch = make(chan *BinlogEvent, 5120)
 	s.ech = make(chan error, 4)
 
 	return s
