Merge pull request #2144 from htran1/gobblin-service-09
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/0ee3cfdc Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/0ee3cfdc Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/0ee3cfdc Branch: refs/heads/master Commit: 0ee3cfdca9dd3edb9d6a45fbffeb186fb10101d1 Parents: 8f32ab4 590b872 Author: Hung Tran <[email protected]> Authored: Thu Oct 19 17:07:32 2017 -0700 Committer: Hung Tran <[email protected]> Committed: Thu Oct 19 17:07:32 2017 -0700 ---------------------------------------------------------------------- gobblin-modules/gobblin-kafka-08/build.gradle | 1 + .../service/SimpleKafkaSpecConsumer.java | 264 ----------------- .../service/SimpleKafkaSpecExecutor.java | 105 ------- .../service/SimpleKafkaSpecProducer.java | 140 --------- .../service/StreamingKafkaSpecConsumer.java | 173 ----------- .../kafka/client/Kafka09ConsumerClient.java | 19 +- .../client/AbstractBaseKafkaConsumerClient.java | 3 +- .../gobblin-service-kafka/build.gradle | 44 +++ .../service/AvroJobSpecDeserializer.java | 70 +++++ .../service/SimpleKafkaSpecConsumer.java | 287 +++++++++++++++++++ .../service/SimpleKafkaSpecExecutor.java | 102 +++++++ .../service/SimpleKafkaSpecProducer.java | 157 ++++++++++ .../service/StreamingKafkaSpecConsumer.java | 175 +++++++++++ 13 files changed, 855 insertions(+), 685 deletions(-) ----------------------------------------------------------------------
