From c21a53a0eb5a4832380441f56607434e18c0dfb4 Mon Sep 17 00:00:00 2001 From: Xieql Date: Wed, 5 Jan 2022 14:02:47 +0800 Subject: [PATCH] [skip e2e] Improve annotation (#14709) Signed-off-by: Xieql --- internal/msgstream/mq_msgstream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/msgstream/mq_msgstream.go b/internal/msgstream/mq_msgstream.go index 5d4394fd91..52f82a2eec 100644 --- a/internal/msgstream/mq_msgstream.go +++ b/internal/msgstream/mq_msgstream.go @@ -171,7 +171,7 @@ func (ms *mqMsgStream) AsConsumerWithPosition(channels []string, subName string, func (ms *mqMsgStream) AsReader(channels []string, subName string) { for _, channel := range channels { if len(channel) == 0 { - log.Error("MsgStream asProducer's channel is a empty string") + log.Error("MsgStream asProducer's channel is an empty string") break } fn := func() error {