mirror of
https://gitee.com/milvus-io/milvus.git
synced 2024-12-02 03:48:37 +08:00
[skip e2e] Improve annotation (#14709)
Signed-off-by: Xieql <qianglong.xie@zilliz.com>
This commit is contained in:
parent
7031a511ce
commit
c21a53a0eb
@ -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 {
|
||||
|
Loading…
Reference in New Issue
Block a user