pulsar-client-go
pulsar-client-go copied to clipboard
Add parition reader to solve the Reader fragmented read data.
- fix issues #553 detail
list:
- add partition reader file; /pulsar/reader_partition.go
- update reader Impl /pulsar/reader_impl.go ;
@EAHITechnology Nick work, can you add test case for this feature?
@EAHITechnology Please add unit test case for this change?
We can use the following code to create a topic with 3 partitions
topic := newTopicName()
testURL := adminURL + "/" + "admin/v2/persistent/public/default/" + topic + "/partitions"
makeHTTPCall(t, http.MethodPut, testURL, "3")