tree 6af1e583b5b852f566b743c7778fade156d453f1
parent df2ea94467cdc647024feb05836fc45f474b5a95
author Jan Van Besien <janvanbesien@ngdata.com> 1582291379 +0100
committer Josh Wills <jwills@apache.org> 1582391990 -0800

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>