ConcurrencyPractitioner commented on issue #3273: Adding config auto.offset.reset to PulsarKafkaConsumer URL: https://github.com/apache/pulsar/pull/3273#issuecomment-451347861 Ok, so I noticed some curious behavior while looking through the code. In poll(), if we find there is an invalid offset position, we would seek to the end (default value of auto.offset.reset is latest). It would work just fine. However, when we call seekToBeginning or seekToEnd directly after such a poll() operation, it seems to fail because of some ConnectionError (i.e. not able to find ClientCnx -- Closed Connection). I'm not really sure what is causing this, so I am open to pointers.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on 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
