mirror of https://github.com/milvus-io/milvus.git
[skip ci]Add comment for rocksmq reader (#13013)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/13021/head
parent
0f387871c1
commit
490f8b50e1
|
@ -12,6 +12,7 @@ type rmqReader struct {
|
|||
r rocksmq.Reader
|
||||
}
|
||||
|
||||
// Topic returns the topic name of a reader
|
||||
func (rr *rmqReader) Topic() string {
|
||||
return rr.r.Topic()
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue