From 844edfa420c8dd18be0f6c1c9e4989800093bdfc Mon Sep 17 00:00:00 2001 From: Zixiong Liu Date: Wed, 30 Dec 2020 13:07:43 +0800 Subject: [PATCH] cherry pick #1250 to release-5.0-rc Signed-off-by: ti-srebot --- cdc/sink/mq.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cdc/sink/mq.go b/cdc/sink/mq.go index acfbca638cb..42027d9550f 100644 --- a/cdc/sink/mq.go +++ b/cdc/sink/mq.go @@ -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") @@ -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.