commit dd3ba47f8742e114aea4acc106283871bcd2301b
author Richard Yu <yohan.richard.yu@gmail.com> Fri Jan 04 19:05:01 2019 -0800
committer Matteo Merli <mmerli@apache.org> Fri Jan 04 19:05:01 2019 -0800
tree 93bc589d90f34e49ef156f54851b56282d1d5e67
parent 7d204103b4faec7a34bc178c3c657fc02fc6e5d5

Adding config auto.offset.reset to PulsarKafkaConsumer (#3273)

* Adding config auto.offset.reset to PulsarKafkaConsumer

* Adding similar behavior to poll

* Update pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java

Co-Authored-By: ConcurrencyPractitioner <yohan.richard.yu@gmail.com>

* Adding some changes

* Fixing indentation

* Modifying postion method

* Adding entry to compatibility matridx

* Removing enum

* Fixing indentation and policy

* removing indents

* Fixing indent

* Adding log statements

* Modifying seekToEnd behavior

* Adding check

* updating position

* Reverting accidentaldeletion