Function newTestAdmin

admin_test.go:2138–2141

newTestAdmin builds a V2.1 ClusterAdmin against the given seed broker with retry backoff disabled and auto-cleanup.

(t *testing.T, seed *MockBroker)

// newTestAdmin builds a V2.1 ClusterAdmin against the given seed broker with
// retry backoff disabled and auto-cleanup.
func newTestAdmin(t *testing.T, seed *MockBroker) ClusterAdmin {
	t.Helper()
	return newTestAdminAt(t, V2_1_0_0, seed)
}

// newTestAdminAt is like newTestAdmin but with a caller-chosen KafkaVersion.
func newTestAdminAt(t *testing.T, version KafkaVersion, seed *MockBroker) ClusterAdmin {