diff --git a/command/kafka/command_cluster.go b/command/kafka/command_cluster.go
index eaee90b9..0bb56aca 100644
--- a/command/kafka/command_cluster.go
+++ b/command/kafka/command_cluster.go
@@ -295,6 +295,7 @@ func (c *clusterCommand) createKafkaCreds(ctx context.Context, kafkaClusterID st
 		LogicalClusters: []*authv1.ApiKey_Cluster{
 			{Id: kafkaClusterID},
 		},
+		AccountId:c.config.Auth.Account.Id,
 	})
 
 	if err != nil {