# Job specific propertiesjob.name=PullFromKafkajob.group=Kafkajob.description=Pull content from a Kafka queuejob.lock.dir=/DevelopmentUtils/gobblin-dist/job_locks/job.lock.enabled=truejob.runonce=true
# Job type propertieslauncher.type=LOCAL
# Source propertiessource.class=gobblin.source.extractor.extract.kafka.KafkaSourcetopic.blacklist=topic.whitelist=testtopics.move.to.latest.offset=move.to.earliest.offset.allowed=topic.name=testleader.hostandport=localhost:2181avg.event.size=estimated.data.size=
# Extract propertiesextract.namespace=gobblin.source.extractor.extract.kafka
# Writer propertieswriter.destination.type=HDFSwriter.output.format=AVRO
# Data publisher propertiesdata.publisher.type=gobblin.publisher.BaseDataPublisher
2015-06-02 09:47:37 CDT ERROR [JobScheduler-0] gobblin.scheduler.JobScheduler 275 - Failed to launch and run job PullFromKafkajava.lang.InstantiationException at sun.reflect.InstantiationExceptionConstructorAccessorImpl.newInstance(InstantiationExceptionConstructorAccessorImpl.java:48) at java.lang.reflect.Constructor.newInstance(Constructor.java:422) at java.lang.Class.newInstance(Class.java:442) at gobblin.runtime.JobContext.<init>(JobContext.java:105) at gobblin.runtime.AbstractJobLauncher.<init>(AbstractJobLauncher.java:104) at gobblin.runtime.local.LocalJobLauncher.<init>(LocalJobLauncher.java:66) at gobblin.runtime.JobLauncherFactory.newJobLauncher(JobLauncherFactory.java:55) at gobblin.scheduler.JobScheduler.runJob(JobScheduler.java:267) at gobblin.scheduler.JobScheduler$NonScheduledJobRunner.run(JobScheduler.java:475) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)2015-06-02 09:47:37 CDT ERROR [JobScheduler-0] gobblin.scheduler.JobScheduler$NonScheduledJobRunner 477 - Failed to run job PullFromKafkagobblin.runtime.JobException: Failed to launch and run job PullFromKafka at gobblin.scheduler.JobScheduler.runJob(JobScheduler.java:276) at gobblin.scheduler.JobScheduler$NonScheduledJobRunner.run(JobScheduler.java:475) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)Caused by: java.lang.InstantiationException at sun.reflect.InstantiationExceptionConstructorAccessorImpl.newInstance(InstantiationExceptionConstructorAccessorImpl.java:48) at java.lang.reflect.Constructor.newInstance(Constructor.java:422) at java.lang.Class.newInstance(Class.java:442) at gobblin.runtime.JobContext.<init>(JobContext.java:105) at gobblin.runtime.AbstractJobLauncher.<init>(AbstractJobLauncher.java:104) at gobblin.runtime.local.LocalJobLauncher.<init>(LocalJobLauncher.java:66) at gobblin.runtime.JobLauncherFactory.newJobLauncher(JobLauncherFactory.java:55) at gobblin.scheduler.JobScheduler.runJob(JobScheduler.java:267) ... 6 more
job.name=test
job.group=test
job.description=test
job.disabled=false
source.class=gobblin.source.extractor.extract.kafka.KafkaSimpleSource
converter.classes=gobblin.converter.IdentityConverter
extract.namespace=test
topic.whitelist=<optional>
topic.blacklist=<optional>
kafka.brokers=<kafka-brokers>
writer.fs.uri=file://localhost/
writer.builder.class=gobblin.writer.SimpleDataWriterBuilder
simple.writer.prepend.size=<prepend size>
simple.writer.delimiter=<delimiter>
data.publisher.type=<publisher>