[Improve] Add admin api HealthCheckWithTopicVersion

integration-tests/tokens/admin-token

@@ -0,0 +1 @@
+eyJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJhZG1pbiJ9.MKSR5Mb2wu_FQlMYACv2i4ubMCn4h4Dj_aIDo1dPsDk

pulsaradmin/pkg/admin/brokers.go

@@ -53,8 +53,11 @@ type Brokers interface {
 	// GetAllDynamicConfigurations returns values of all overridden dynamic-configs
 	GetAllDynamicConfigurations() (map[string]string, error)
 
-	// HealthCheck run a health check on the broker
+	// Deprecated: Use HealthCheckWithTopicVersion instead
 	HealthCheck() error
+
+	// HealthCheckWithTopicVersion run a health check on the broker
+	HealthCheckWithTopicVersion(utils.TopicVersion) error
 }
 
 type broker struct {
@@ -142,9 +145,14 @@ func (b *broker) GetAllDynamicConfigurations() (map[string]string, error) {
 }
 
 func (b *broker) HealthCheck() error {
+	return b.HealthCheckWithTopicVersion(utils.TopicVersionV1)
+}
+func (b *broker) HealthCheckWithTopicVersion(topicVersion utils.TopicVersion) error {
 	endpoint := b.pulsar.endpoint(b.basePath, "/health")
 
-	buf, err := b.pulsar.Client.GetWithQueryParams(endpoint, nil, nil, false)
+	buf, err := b.pulsar.Client.GetWithQueryParams(endpoint, nil, map[string]string{
+		"topicVersion": topicVersion.String(),
+	}, false)
 	if err != nil {
 		return err
 	}

pulsaradmin/pkg/admin/brokers_test.go

@@ -0,0 +1,44 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package admin
+
+import (
+	"os"
+	"testing"
+
+	"github.com/apache/pulsar-client-go/pulsaradmin/pkg/admin/config"
+	"github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestBrokerHealthCheckWithTopicVersion(t *testing.T) {
+	readFile, err := os.ReadFile("../../../integration-tests/tokens/admin-token")
+	assert.NoError(t, err)
+	cfg := &config.Config{
+		Token: string(readFile),
+	}
+	admin, err := New(cfg)
+	assert.NoError(t, err)
+	assert.NotNil(t, admin)
+	err = admin.Brokers().HealthCheck()
+	assert.NoError(t, err)
+	err = admin.Brokers().HealthCheckWithTopicVersion(utils.TopicVersionV1)
+	assert.NoError(t, err)
+	err = admin.Brokers().HealthCheckWithTopicVersion(utils.TopicVersionV2)
+	assert.NoError(t, err)
+}

pulsaradmin/pkg/utils/data.go

@@ -473,3 +473,14 @@ type GetStatsOptions struct {
 	ExcludePublishers        bool `json:"exclude_publishers"`
 	ExcludeConsumers         bool `json:"exclude_consumers"`
 }
+
+type TopicVersion string
+
+const (
+	TopicVersionV1 TopicVersion = "V1"
+	TopicVersionV2 TopicVersion = "V2"
+)
+
+func (t TopicVersion) String() string {
+	return string(t)
+}