You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/03/30 04:15:58 UTC
[pulsar-client-go] branch master updated: Cleanup topics after unit tests (#755)
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 <zi...@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)
}