tiny fix the comment.

pingcap · Apr 19, 2022 · 606639b · 606639b
1 parent b59d0b1
commit 606639b
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/cdc/sink/mq.go b/cdc/sink/mq.go
@@ -309,8 +309,6 @@ func (k *mqSink) EmitDDLEvent(ctx context.Context, ddl *model.DDLEvent) error {
 	return errors.Trace(err)
 }
 
-// Close the mqSink
-// Caller can pass a canceled context to make sure this is non-blocking.
 // Close the producer asynchronously, does not care closed successfully or not.
 func (k *mqSink) Close(ctx context.Context) error {
 	go k.mqProducer.Close()