Skip to content

Commit

Permalink
cherry pick #1250 to release-4.0
Browse files Browse the repository at this point in the history
Signed-off-by: ti-srebot <[email protected]>
  • Loading branch information
liuzix authored and ti-srebot committed Dec 30, 2020
1 parent 6b7fb14 commit de91691
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cdc/sink/mq.go
Original file line number Diff line number Diff line change
Expand Up @@ -428,7 +428,7 @@ func newKafkaSaramaSink(ctx context.Context, sinkURI *url.URL, filter *filter.Fi

s = sinkURI.Query().Get("max-batch-size")
if s != "" {
opts["max-message-bytes"] = s
opts["max-batch-size"] = s
}

s = sinkURI.Query().Get("compression")
Expand Down Expand Up @@ -498,7 +498,7 @@ func newPulsarSink(ctx context.Context, sinkURI *url.URL, filter *filter.Filter,

s = sinkURI.Query().Get("max-batch-size")
if s != "" {
opts["max-message-bytes"] = s
opts["max-batch-size"] = s
}
// For now, it's a place holder. Avro format have to make connection to Schema Registery,
// and it may needs credential.
Expand Down

0 comments on commit de91691

Please sign in to comment.