fix: create non-partitions topic (streamnative#577)

nodece · web-flow · commit 21682acc99d0 · 2022-02-11T13:56:37.000+08:00
Signed-off-by: Zixuan Liu &lt;nodeces@gmail.com&gt;
diff --git a/pkg/pulsar/topic.go b/pkg/pulsar/topic.go
@@ -250,10 +250,13 @@ func (c *pulsarClient) Topics() Topics {
 
 func (t *topics) Create(topic utils.TopicName, partitions int) error {
 	endpoint := t.pulsar.endpoint(t.basePath, topic.GetRestPath(), "partitions")
+	data := &partitions
 	if partitions == 0 {
 		endpoint = t.pulsar.endpoint(t.basePath, topic.GetRestPath())
+		data = nil
 	}
-	return t.pulsar.Client.Put(endpoint, partitions)
+
+	return t.pulsar.Client.Put(endpoint, data)
 }
 
 func (t *topics) Delete(topic utils.TopicName, force bool, nonPartitioned bool) error {

Original file line number	Diff line number	Diff line change
`@@ -250,10 +250,13 @@ func (c *pulsarClient) Topics() Topics {`
`250`	`250`
`251`	`251`	`func (t *topics) Create(topic utils.TopicName, partitions int) error {`
`252`	`252`	`endpoint := t.pulsar.endpoint(t.basePath, topic.GetRestPath(), "partitions")`
	`253`	`+ data := &partitions`
`253`	`254`	`if partitions == 0 {`
`254`	`255`	`endpoint = t.pulsar.endpoint(t.basePath, topic.GetRestPath())`
	`256`	`+ data = nil`
`255`	`257`	`}`
`256`		`- return t.pulsar.Client.Put(endpoint, partitions)`
	`258`	`+`
	`259`	`+ return t.pulsar.Client.Put(endpoint, data)`
`257`	`260`	`}`
`258`	`261`
`259`	`262`	`func (t *topics) Delete(topic utils.TopicName, force bool, nonPartitioned bool) error {`