[pulsar-client-go] branch master updated: Cleanup topics after unit tests (#755)

[mmerli]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new ae400ca  Cleanup topics after unit tests (#755)
ae400ca is described below

commit ae400ca6a8322fe8e124465138ace6d1b2167ba3
Author: Ziyao Wei <ziyao.wei....@gmail.com>
AuthorDate: Wed Mar 30 00:15:51 2022 -0400

    Cleanup topics after unit tests (#755)
---
 pulsar/client_impl_test.go | 8 ++++++--
 pulsar/producer_test.go    | 4 +++-
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/pulsar/client_impl_test.go b/pulsar/client_impl_test.go
index e9e94af..2d83c99 100644
--- a/pulsar/client_impl_test.go
+++ b/pulsar/client_impl_test.go
@@ -348,7 +348,9 @@ func TestTopicPartitions(t *testing.T) {
        defer client.Close()
 
        // Create topic with 5 partitions
-       err = 
httpPut("admin/v2/persistent/public/default/TestGetTopicPartitions/partitions", 
5)
+       topicAdminURL := 
"admin/v2/persistent/public/default/TestGetTopicPartitions/partitions"
+       err = httpPut(topicAdminURL, 5)
+       defer httpDelete(topicAdminURL)
        assert.Nil(t, err)
 
        partitionedTopic := "persistent://public/default/TestGetTopicPartitions"
@@ -697,7 +699,9 @@ func TestHTTPTopicPartitions(t *testing.T) {
        defer client.Close()
 
        // Create topic with 5 partitions
-       err = 
httpPut("admin/v2/persistent/public/default/TestHTTPTopicPartitions/partitions",
 5)
+       topicAdminURL := 
"admin/v2/persistent/public/default/TestHTTPTopicPartitions/partitions"
+       err = httpPut(topicAdminURL, 5)
+       defer httpDelete(topicAdminURL)
        assert.Nil(t, err)
 
        partitionedTopic := 
"persistent://public/default/TestHTTPTopicPartitions"
diff --git a/pulsar/producer_test.go b/pulsar/producer_test.go
index 124c828..3c526bb 100644
--- a/pulsar/producer_test.go
+++ b/pulsar/producer_test.go
@@ -509,7 +509,9 @@ func TestRoundRobinRouterPartitionedProducer(t *testing.T) {
 
 func TestMessageRouter(t *testing.T) {
        // Create topic with 5 partitions
-       err := 
httpPut("admin/v2/persistent/public/default/my-partitioned-topic/partitions", 5)
+       topicAdminURL := 
"admin/v2/persistent/public/default/my-partitioned-topic/partitions"
+       err := httpPut(topicAdminURL, 5)
+       defer httpDelete(topicAdminURL)
        if err != nil {
                t.Fatal(err)
        }