diff --git a/internal/util/mqclient/client.go b/internal/util/mqclient/client.go
index 3efb620b0b..cb3f82db69 100644
--- a/internal/util/mqclient/client.go
+++ b/internal/util/mqclient/client.go
@@ -16,7 +16,7 @@ type Client interface {
 	// CreateReader creates a producer instance
 	CreateReader(options ReaderOptions) (Reader, error)
 
-	// Create a producer instance
+	// CreateProducer creates a producer instance
 	CreateProducer(options ProducerOptions) (Producer, error)
 
 	// Create a consumer instance and subscribe a topic