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)
@@ -853,6 +859,6 @@ func TestNamespaces_Persistence(t *testing.T) {
 	persistence, err = admin.Namespaces().GetPersistence(namespaceName)
 	assert.NoError(t, err)
 	assert.NotNil(t, persistence, "Expected non-nil when persistence is configured")
-	assert.Equal(t, 3, persistence.BookkeeperEnsemble)
-	assert.Equal(t, 2, persistence.BookkeeperWriteQuorum)
+	assert.Equal(t, 1, persistence.BookkeeperEnsemble)
+	assert.Equal(t, 1, persistence.BookkeeperWriteQuorum)
 }

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)
@@ -1377,8 +1377,8 @@ func TestTopics_Persistence(t *testing.T) {
 		func() bool {
 			persistence, err = admin.Topics().GetPersistence(*topicName)
 			return err == nil && persistence != nil &&
-				persistence.BookkeeperEnsemble == 3 &&
-				persistence.BookkeeperWriteQuorum == 2
+				persistence.BookkeeperEnsemble == 1 &&
+				persistence.BookkeeperWriteQuorum == 1
 		},
 		10*time.Second,
 		100*time.Millisecond,