sink(ticdc): address comment

pingcap · Mar 15, 2022 · ed3113a · ed3113a
1 parent ee1567e
commit ed3113a
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/cdc/sink/mq_flush_worker.go b/cdc/sink/mq_flush_worker.go
@@ -66,8 +66,7 @@ func newFlushWorker(encoder codec.EventBatchEncoder, producer producer.Producer,
 
 // batch collects a batch of messages to be sent to the Kafka producer.
 func (w *flushWorker) batch(
-	ctx context.Context,
-	events []mqEvent,
+	ctx context.Context, events []mqEvent,
 ) (int, error) {
 	index := 0
 	max := len(events)