Use admin credentials and test fixes

Author: klevy-toast

pulsaradmin/pkg/admin/namespace_test.go

@@ -18,6 +18,7 @@
 package admin
 
 import (
+	"os"
 	"testing"
 	"time"
 
@@ -791,7 +792,12 @@ func TestNamespaces_Retention(t *testing.T) {
 }
 
 func TestNamespaces_BookieAffinityGroup(t *testing.T) {
-	config := &config.Config{}
+	readFile, err := os.ReadFile("../../../integration-tests/tokens/admin-token")
+	require.NoError(t, err)
+
+	config := &config.Config{
+		Token: string(readFile),
+	}
 	admin, err := New(config)
 	require.NoError(t, err)
 	require.NotNil(t, admin)
@@ -841,9 +847,9 @@ func TestNamespaces_Persistence(t *testing.T) {
 
 	// Set new persistence policy
 	newPersistence := utils.PersistencePolicies{
-		BookkeeperEnsemble:             3,
-		BookkeeperWriteQuorum:          2,
-		BookkeeperAckQuorum:            2,
+		BookkeeperEnsemble:             1,
+		BookkeeperWriteQuorum:          1,
+		BookkeeperAckQuorum:            1,
 		ManagedLedgerMaxMarkDeleteRate: 10.0,
 	}
 	err = admin.Namespaces().SetPersistence(namespaceName, newPersistence)

pulsaradmin/pkg/admin/topic_test.go

@@ -1363,9 +1363,9 @@ func TestTopics_Persistence(t *testing.T) {
 
 	// Set new persistence policy
 	newPersistence := utils.PersistenceData{
-		BookkeeperEnsemble:             3,
-		BookkeeperWriteQuorum:          2,
-		BookkeeperAckQuorum:            2,
+		BookkeeperEnsemble:             1,
+		BookkeeperWriteQuorum:          1,
+		BookkeeperAckQuorum:            1,
 		ManagedLedgerMaxMarkDeleteRate: 10.0,
 	}
 	err = admin.Topics().SetPersistence(*topicName, newPersistence)