[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-16 Thread GitBox
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)

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-13 Thread GitBox
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)

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-13 Thread GitBox
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

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-08 Thread GitBox
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

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-08 Thread GitBox
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

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-08 Thread GitBox
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)

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-08 Thread GitBox
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

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-08 Thread GitBox
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

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #168: [Issue-148][pulsar-client-go] add seek by messageID

2020-01-08 Thread GitBox
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