KafkaSimpleJsonExtractor

2018-04-11 Thread Kidwell, Jack
Hi, Using gobblin_0.10.0, we want to use module, KafkaSimpleJsonExtractor.java in order to see both kafka record keys and values. How does one configure a job to achieve it?

Kafka09ConsumerClient.java

2018-04-11 Thread Kidwell, Jack
Hi, In gobblin-distribution-0.10.0.tar.gz no jar contains the classes defined in Kafka09ConsumerClient.java. Is this expected? Or must I build the jar from source? Thanks.

Re: Kafka09ConsumerClient.java

2018-04-11 Thread Zhixiong Chen
Hi Jack, By default, kafka08 is built into the distribution. If you need kafka09 classes, you need a custom build. Here is the wiki link: https://gobblin.readthedocs.io/en/latest/developer-guide/GobblinModules/ Zhixiong Gobblin Modules - Gobblin