ConcurrencyPractitioner commented on issue #3983: [Issue#3976] [component/client] Adding config for ReaderImpl URL: https://github.com/apache/pulsar/pull/3983#issuecomment-482376378 Alright, I'm not sure if option 2 still works. From log after test rerun: ``` 21:36:55.342 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.pulsar.broker.service.persistent.PersistentMessageFinder@99] INFO org.apache.pulsar.broker.service.persistent.PersistentMessageFinder - [persistent://my-property/my-ns/testReaderAtSelectedTimestamp][reader-3f11d6ab7e] Found position 3:2 closest to provided timestamp 1554871008242 21:36:55.342 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.pulsar.broker.service.Consumer@369] INFO org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://my-property/my-ns/testReaderAtSelectedTimestamp, name=reader-3f11d6ab7e}, consumerId=0, consumerName=2a5c6, address=/127.0.0.1:61416} 21:36:55.344 [pulsar-client-io-187-1:org.apache.pulsar.client.impl.ClientCnx@600] INFO org.apache.pulsar.client.impl.ClientCnx - [localhost/127.0.0.1:15087] Broker notification of Closed consumer: 0 21:36:55.344 [pulsar-client-io-187-1:org.apache.pulsar.client.impl.ConnectionHandler@109] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://my-property/my-ns/testReaderAtSelectedTimestamp] [reader-3f11d6ab7e] Closed connection [id: 0x2ac3250a, L:/127.0.0.1:61416 - R:localhost/127.0.0.1:15087] -- Will try again in 0.1 s 21:36:55.345 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer@159] INFO org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://my-property/my-ns/testReaderAtSelectedTimestamp, name=reader-3f11d6ab7e}, consumerId=0, consumerName=2a5c6, address=/127.0.0.1:61416} 21:36:55.345 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.pulsar.broker.service.persistent.PersistentSubscription@499] INFO org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://my-property/my-ns/testReaderAtSelectedTimestamp][reader-3f11d6ab7e] Successfully closed subscription [NonDurableCursorImpl{ledger=my-property/my-ns/persistent/testReaderAtSelectedTimestamp, ackPos=3:-1, readPos=3:10}] 21:36:55.346 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.pulsar.broker.service.persistent.PersistentSubscription@406] INFO org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://my-property/my-ns/testReaderAtSelectedTimestamp][reader-3f11d6ab7e] Successfully disconnected consumers from subscription, proceeding with cursor reset 21:36:55.346 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.bookkeeper.mledger.impl.ManagedCursorImpl@822] INFO org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [my-property/my-ns/persistent/testReaderAtSelectedTimestamp] Initiate reset position to 3:2 on cursor reader-3f11d6ab7e 21:36:55.346 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.bookkeeper.mledger.impl.ManagedCursorImpl$7@861] INFO org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [my-property/my-ns/persistent/testReaderAtSelectedTimestamp] reset position to 3:2 before current read position 3:10 on cursor reader-3f11d6ab7e 21:36:55.346 [bookkeeper-ml-workers-OrderedExecutor-1-0:org.apache.pulsar.broker.service.ServerCnx@1154] INFO org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:61416] [persistent://my-property/my-ns/testReaderAtSelectedTimestamp][reader-3f11d6ab7e] Reset subscription to publish time 1554871008242 21:36:55.347 [pulsar-client-io-187-1:org.apache.pulsar.client.impl.ConsumerImpl@1379] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://my-property/my-ns/testReaderAtSelectedTimestamp][reader-3f11d6ab7e] Successfully reset subscription to publish time 1554871008242 !!!!!!!!! FAILURE-- [TestClass name=class org.apache.pulsar.client.api.TopicReaderTest].null([])------- ``` So the seek was supposed to have worked judging from the log ouput. And the cursor was reset from 3:0 to 3:2. Although obviously, the test still failed afterwards.
---------------------------------------------------------------- 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: us...@infra.apache.org With regards, Apache Git Services
