create topic first

freeznet · Jun 22, 2021 · 704c968 · 704c968
1 parent 68d2abe
commit 704c968
Showing 1 changed file with 30 additions and 5 deletions.
diff --git a/pulsar/client_impl_test.go b/pulsar/client_impl_test.go
@@ -347,7 +347,7 @@ func TestTopicPartitions(t *testing.T) {
 	assert.Nil(t, err)
 	defer client.Close()
 
-	// Create topic with 5 partitions
+	// Create topic
 	err = httpPut("admin/v2/persistent/public/default/TestGetTopicPartitions/partitions", 5)
 	assert.Nil(t, err)
 
@@ -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)
@@ -728,8 +749,12 @@ func TestRetryWithMultipleHttpHosts(t *testing.T) {
 	assert.Nil(t, err)
 	defer client.Close()
 
-	topic := "persistent://public/default/retry-multiple-hosts-" + generateRandomName()
+	topic := "retry-multiple-hosts-" + generateRandomName()
+
+	err = httpPut("admin/v2/persistent/public/default/"+topic, nil)
+	assert.Nil(t, err)
 
+	topic = "persistent://public/default/" + topic
 	producer, err := client.CreateProducer(ProducerOptions{
 		Topic: topic,
 	})