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)
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_r365925340
##
File path: pulsar/consumer_impl.go
##
@@ -319,6 +302,15 @@ func (c *consumer)
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_r365924851
##
File path: pulsar/consumer_multitopic.go
##
@@ -160,3 +160,14 @@ func (c
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_r364347639
##
File path: pulsar/consumer_impl.go
##
@@ -364,3 +356,21 @@ func
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_r364349981
##
File path: pulsar/consumer_test.go
##
@@ -202,192 +157,160 @@ func
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_r364342087
##
File path: pulsar/consumer_impl.go
##
@@ -319,6 +302,15 @@ func (c *consumer)
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_r364342728
##
File path: pulsar/consumer_partition.go
##
@@ -256,6 +256,50 @@ func (pc
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_r364354077
##
File path: pulsar/test_helper.go
##
@@ -164,3 +173,55 @@ func topicPath(topic
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_r364343418
##
File path: pulsar/test_helper.go
##
@@ -150,6 +153,12 @@ func deleteTopic(topic