diff --git a/internal/util/rocksmq/client/rocksmq/producer_impl.go b/internal/util/rocksmq/client/rocksmq/producer_impl.go index 4eecc2a35b..9bf4e422d3 100644 --- a/internal/util/rocksmq/client/rocksmq/producer_impl.go +++ b/internal/util/rocksmq/client/rocksmq/producer_impl.go @@ -21,6 +21,7 @@ import ( // assertion make sure implementation var _ Producer = (*producer)(nil) +// producer contains a client instance and topic name type producer struct { // client which the producer belong to c *client