diff --git a/admin/admin.go b/admin/admin.go
index 62175af4..a92a25c7 100644
--- a/admin/admin.go
+++ b/admin/admin.go
@@ -102,6 +102,9 @@ func NewAdmin(opts ...AdminOption) (*admin, error) {
 	if err != nil {
 		return nil, err
 	}
+	if !defaultOpts.Credentials.IsEmpty() {
+		namesrv.SetCredentials(defaultOpts.Credentials)
+	}
 
 	cli := internal.GetOrNewRocketMQClient(defaultOpts.ClientOptions, nil)
 	if cli == nil {
diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index bd05cbff..5d8fc6db 100644
--- a/consumer/pull_consumer.go
+++ b/consumer/pull_consumer.go
@@ -92,6 +92,9 @@ func NewPullConsumer(options ...Option) (*defaultPullConsumer, error) {
 	if err != nil {
 		return nil, errors.Wrap(err, "new Namesrv failed.")
 	}
+	if !defaultOpts.Credentials.IsEmpty() {
+		srvs.SetCredentials(defaultOpts.Credentials)
+	}
 
 	defaultOpts.Namesrv = srvs
 	dc := &defaultConsumer{