sinkv2(ticdc): add comment

pingcap · Jul 20, 2022 · 5135a6b · 5135a6b
1 parent 20e5ece
commit 5135a6b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/sinkv2/eventsink/mq/mq_sink.go b/cdc/sinkv2/eventsink/mq/mq_sink.go
@@ -116,7 +116,7 @@ func (s *sink) WriteEvents(rows ...*eventsink.RowChangeCallbackableEvent) error
 			return errors.Trace(err)
 		}
 		partition := s.eventRouter.GetPartitionForRowChange(row.Event, partitionNum)
-		// This never be blocked.
+		// This never be blocked because this is an unbounded channel.
 		s.worker.msgChan.In() <- mqEvent{
 			key: mqv1.TopicPartitionKey{
 				Topic: topic, Partition: partition,