diff --git a/internal/util/rocksmq/client/rocksmq/consumer.go b/internal/util/rocksmq/client/rocksmq/consumer.go index e9e0754aee..0467637ccb 100644 --- a/internal/util/rocksmq/client/rocksmq/consumer.go +++ b/internal/util/rocksmq/client/rocksmq/consumer.go @@ -47,7 +47,7 @@ type ConsumerOptions struct { MessageChannel chan Message } -// ConsumerMessage is the message content of a consumer message +// Message is the message content of a consumer message type Message struct { Consumer MsgID UniqueID