create topic first

apache · Jun 22, 2021 · 1a4915b · 1a4915b
1 parent 68d2abe
commit 1a4915b
Showing 1 changed file with 26 additions and 5 deletions.
diff --git a/pulsar/client_impl_test.go b/pulsar/client_impl_test.go
@@ -347,8 +347,8 @@ func TestTopicPartitions(t *testing.T) {
 	assert.Nil(t, err)
 	defer client.Close()
 
-	// Create topic with 5 partitions
-	err = httpPut("admin/v2/persistent/public/default/TestGetTopicPartitions/partitions", 5)
+	// Create topic
+	err = httpPut("admin/v2/persistent/public/default/TestGetTopicPartitions", nil)
 	assert.Nil(t, err)
 
 	partitionedTopic := "persistent://public/default/TestGetTopicPartitions"
@@ -624,8 +624,14 @@ func TestHTTPSInsecureConnection(t *testing.T) {
 	})
 	assert.NoError(t, err)
 
+	topicName := newTopicName()
+
+	// Create topic
+	err = httpPut(fmt.Sprintf("admin/v2/persistent/public/default/%s", topicName), nil)
+	assert.Nil(t, err)
+
 	producer, err := client.CreateProducer(ProducerOptions{
-		Topic: newTopicName(),
+		Topic: topicName,
 	})
 
 	assert.NoError(t, err)
@@ -641,8 +647,14 @@ func TestHTTPSConnection(t *testing.T) {
 	})
 	assert.NoError(t, err)
 
+	topicName := newTopicName()
+
+	// Create topic
+	err = httpPut(fmt.Sprintf("admin/v2/persistent/public/default/%s", topicName), nil)
+	assert.Nil(t, err)
+
 	producer, err := client.CreateProducer(ProducerOptions{
-		Topic: newTopicName(),
+		Topic: topicName,
 	})
 
 	assert.NoError(t, err)
@@ -659,8 +671,14 @@ func TestHTTPSConnectionHostNameVerification(t *testing.T) {
 	})
 	assert.NoError(t, err)
 
+	topicName := newTopicName()
+
+	// Create topic with 5 partitions
+	err = httpPut(fmt.Sprintf("admin/v2/persistent/public/default/%s", topicName), nil)
+	assert.Nil(t, err)
+
 	producer, err := client.CreateProducer(ProducerOptions{
-		Topic: newTopicName(),
+		Topic: topicName,
 	})
 
 	assert.NoError(t, err)
@@ -711,6 +729,9 @@ func TestHTTPTopicPartitions(t *testing.T) {
 	}
 
 	// Non-Partitioned topic
+	err = httpPut("admin/v2/persistent/public/default/TestHTTPTopicPartitions-nopartitions", nil)
+	assert.Nil(t, err)
+
 	topic := "persistent://public/default/TestHTTPTopicPartitions-nopartitions"
 
 	partitions, err = client.TopicPartitions(topic)