| commit | d4506c97b676c82ee0c7835bba4164afef118650 | [log] [tgz] |
|---|---|---|
| author | Rajan Dhabalia <rdhabalia@apache.org> | Tue Aug 06 09:53:56 2019 -0700 |
| committer | GitHub <noreply@github.com> | Tue Aug 06 09:53:56 2019 -0700 |
| tree | 69113436ae626546181baf5229093a814573e6c0 | |
| parent | 9d3996150c455cd87c25237a8346b65bf4a8211e [diff] |
Add support of pulsar-kafka-adapter for kafka-0.8 api (#4797) * Add support pulsar-kafka-adapter for kafka-0.8 api clean up pulsar-kafka adapter add tests add low level consumer add simple consumer corrected pulsar-client-kafka_0_8 fix the module name add batch and partitioned-topic support fix headers add getOffset api support added pulsarOffset request/response clean up * add pulsar-kafka integration test * use earliestTime offset * add default serializer/de