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

wangjia007bond 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_r364548048 ## File path: pulsar/consumer_test.go ## @@ -202,192 +157,160 @@ func TestConsumerW

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

wangjia007bond 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_r364552144 ## File path: pulsar/test_helper.go ## @@ -150,6 +153,12 @@ func deleteTopic(topic

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

wangjia007bond 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_r364552005 ## File path: pulsar/consumer_impl.go ## @@ -319,6 +302,15 @@ func (c *consumer) Cl

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

wangjia007bond 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_r364552164 ## File path: pulsar/consumer_test.go ## @@ -663,128 +539,144 @@ func TestConsumerN

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

wangjia007bond 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_r364552036 ## File path: pulsar/consumer_partition.go ## @@ -256,6 +256,50 @@ func (pc *partit

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

wangjia007bond 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_r364552419 ## File path: pulsar/consumer_impl.go ## @@ -364,3 +356,21 @@ func toProtoInitialPo

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

wangjia007bond 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_r364552454 ## File path: pulsar/test_helper.go ## @@ -164,3 +173,55 @@ func topicPath(topic st

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

wangjia007bond 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_r364552477 ## File path: pulsar/consumer_test.go ## @@ -663,128 +539,144 @@ func TestConsumerN

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

wangjia007bond 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_r367292535 ## File path: pulsar/consumer_impl.go ## @@ -319,6 +302,15 @@ func (c *consumer) Cl