| commit | 1da1f9c03db4d6b5924ee775d16f31119793d5ca | [log] [tgz] |
|---|---|---|
| author | Jan Van Besien <janvanbesien@ngdata.com> | Fri Feb 21 14:22:59 2020 +0100 |
| committer | Josh Wills <jwills@apache.org> | Sat Feb 22 09:19:50 2020 -0800 |
| tree | 6af1e583b5b852f566b743c7778fade156d453f1 | |
| parent | df2ea94467cdc647024feb05836fc45f474b5a95 [diff] |
Update to kafka 2.2.1 Remove duplication of KafkaData, KafkaSource, KafkaInputFormat in order to only retain the variants from org.apache.crunch.kafka.record that were already mostly compatible with kafka 2.2.1. Fix some remaining incompatibilities, in particular related to reading offset information from the broker. Signed-off-by: Josh Wills <jwills@apache.org>