cckellogg commented on a change in pull request #168:
[Issue-148][pulsar-client-go] add seek by messageID
URL: https://github.com/apache/pulsar-client-go/pull/168#discussion_r367564038
##########
File path: pulsar/consumer_impl.go
##########
@@ -319,6 +302,15 @@ func (c *consumer) Close() {
})
}
+func (c *consumer) Seek(msgID MessageID) error {
Review comment:
If there is more than 1 consumer in the list then it's a partitioned topic.
If topic is partitioned and has only 1 partition or the topic is not
partitioned then there will be 1 consumer which is kind of the same thing.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
