You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/01/02 04:10:34 UTC

[GitHub] ConcurrencyPractitioner opened a new pull request #3273: Adding config auto.offset.reset to PulsarKafkaConsumer

ConcurrencyPractitioner opened a new pull request #3273: Adding config auto.offset.reset to PulsarKafkaConsumer
URL: https://github.com/apache/pulsar/pull/3273
 
 
   ### Motivation
   
   Currently, in KafkaConsumer, there is a new config which is called auto.offset.reset. It is currently ignored in PulsarKafkaConsumer, so we wish to implement it.
   
   ### Modifications
   
   We added some new code which defined the behavior if auto.offset.reset == "earliest" or "latest".
   
   ### Result
   
   It would automatically seek to the last offset or the first offset depending on the set config.

----------------------------------------------------------------
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:
users@infra.apache.org


With regards,
Apache Git Services