diff --git a/internal/util/mqclient/rmq_producer.go b/internal/util/mqclient/rmq_producer.go index 2fcdeaca1c..ff2614d97f 100644 --- a/internal/util/mqclient/rmq_producer.go +++ b/internal/util/mqclient/rmq_producer.go @@ -23,6 +23,7 @@ type rmqProducer struct { p rocksmq.Producer } +// Topic returns the topic of rmq producer func (rp *rmqProducer) Topic() string { return rp.p.Topic() }