We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b5cc10c commit 8329023Copy full SHA for 8329023
drivers/mysql/mysql/extractor.go
@@ -915,9 +915,7 @@ func (e *Extractor) StreamEvents() error {
915
entries.Entries = append(entries.Entries, binlogEntry)
916
entriesSize += entryCtx.OriginalSize
917
918
- if entriesSize >= e.mysqlContext.GroupMaxSize ||
919
- int64(len(entries.Entries)) == e.mysqlContext.ReplChanBufferSize {
920
-
+ if entriesSize >= e.mysqlContext.GroupMaxSize {
921
e.logger.Debug("incr. send by GroupLimit",
922
"entriesSize", entriesSize,
923
"groupMaxSize", e.mysqlContext.GroupMaxSize,
0 commit comments