commit e4bff461989c76991f6baeade3ca85631f40a7a4
author Marvin Cai <cai19930303@gmail.com> Thu Mar 28 13:33:58 2019 -0700
committer Matteo Merli <mmerli@apache.org> Thu Mar 28 13:33:58 2019 -0700
tree b3c00bca787157402d553beb9300542c5f0ebf6a
parent e30c5526f22312753b60a377ea977f633f3b9ac8

Support Kafka's ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG in PulsarKafkaConsumer. (#3911)

* Support Kafka's ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG in PulsarKafkaConsumer.
Apply onConsume in poll() before returning the ConsumerRecords,
apply onCommit in doCommitOffsets() before committing all offsets.

Also apply doc to reflect support for ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG.

* Update error message for applying onConsume and onCommit for interceptors to include the specific interceptor name.