NullPointerException from kafka tranquility

Hi,
I’m trying to get data from Kafka into druid by using tranquility. This is my first time using druid besides the quickstart.
I’m using Druid Version 0.9.2 and I’m getting a NullPointerException when I try to run tranquility with the config file

Here is the error log:

2018-05-30 17:17:07,335 [KafkaConsumer-0] INFO c.m.t.kafka.writer.WriterController - Creating EventWriter for topic [AweFormSubmit] using dataSource [AweFormSubmit-kafka]

``
2018-05-30 17:17:07,339 [KafkaConsumer-1] ERROR c.m.tranquility.kafka.KafkaConsumer - Exception:

java.lang.NullPointerException: null

at io.druid.segment.indexing.DataSchema.getParser(DataSchema.java:116) ~[io.druid.druid-server-0.9.0.jar:0.9.0]

at com.metamx.tranquility.druid.DruidBeams$.fromConfigInternal(DruidBeams.scala:293) ~[io.druid.tranquility-core-0.8.0.jar:0.8.0]

at com.metamx.tranquility.druid.DruidBeams$.fromConfig(DruidBeams.scala:199) ~[io.druid.tranquility-core-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.KafkaBeamUtils$.createTranquilizer(KafkaBeamUtils.scala:40) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.KafkaBeamUtils.createTranquilizer(KafkaBeamUtils.scala) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.writer.TranquilityEventWriter.(TranquilityEventWriter.java:64) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.writer.WriterController.createWriter(WriterController.java:171) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.writer.WriterController.getWriter(WriterController.java:98) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.KafkaConsumer$2.run(KafkaConsumer.java:231) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_161]

at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_161]

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_161]

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_161]

at java.lang.Thread.run(Thread.java:748) [na:1.8.0_161]

2018-05-30 17:17:07,339 [KafkaConsumer-0] ERROR c.m.tranquility.kafka.KafkaConsumer - Exception:

java.lang.NullPointerException: null

at io.druid.segment.indexing.DataSchema.getParser(DataSchema.java:116) ~[io.druid.druid-server-0.9.0.jar:0.9.0]

at com.metamx.tranquility.druid.DruidBeams$.fromConfigInternal(DruidBeams.scala:293) ~[io.druid.tranquility-core-0.8.0.jar:0.8.0]

at com.metamx.tranquility.druid.DruidBeams$.fromConfig(DruidBeams.scala:199) ~[io.druid.tranquility-core-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.KafkaBeamUtils$.createTranquilizer(KafkaBeamUtils.scala:40) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.KafkaBeamUtils.createTranquilizer(KafkaBeamUtils.scala) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.writer.TranquilityEventWriter.(TranquilityEventWriter.java:64) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.writer.WriterController.createWriter(WriterController.java:171) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.writer.WriterController.getWriter(WriterController.java:98) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at com.metamx.tranquility.kafka.KafkaConsumer$2.run(KafkaConsumer.java:231) ~[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_161]

at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_161]

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_161]

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_161]

at java.lang.Thread.run(Thread.java:748) [na:1.8.0_161]

2018-05-30 17:17:07,339 [KafkaConsumer-0] INFO c.m.tranquility.kafka.KafkaConsumer - Shutting down - attempting to flush buffers and commit final offsets

2018-05-30 17:17:07,344 [KafkaConsumer-0] INFO org.apache.zookeeper.ZooKeeper - Session: 0x2619a2967a2a5dc closed

2018-05-30 17:17:07,344 [KafkaConsumer-1-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down

And here is my config file

{

“dataSources” : {

“AweFormSubmit-kafka” : {

“spec” : {

“dataSchema” : {

“dataSource” : “AweFormSubmit-kafka”,

“parser” : {

“type” : “string”,

“parseSpec” : {

“timestampSpec” : {

“column” : “form-start-date”,

“format” : “M/d/yyyy h:m:s a”

},

“dimensionssSpec” : {

“dimensions” : [

“ESource”,

“city”,

“State”,

“ZipCode”,

“qform-type”,

“cchannel”,

“csource”,

“cname”,

“cmethod”,

“product”,

“product-type”,

“homeloan-product-type”,

“loan-class”,

“template”,

“exchange-lead-type”,

“IPAddress”

]

},

“format” : “json”

}

},

“granularitySpec” : {

“type” : “uniform”,

“segmentGranularity” : “minute”,

“queryGranularity” : “none”

},

“metricsSpec” : [

{

“type” : “count”,

“name” : “count”,

},

{

“type” : “doubleMax”,

“name” : “Credit Score”,

“fieldName” : “CreditScore”

},

{

“type” : “doubleMax”,

“name” : “Amount”,

                        "fieldName" : "Amount"

},

{

“type” : “doubleSum”,

“name” : “AmountSum”,

“fieldName” : “Amount”

}

]

},

“ioConfig” : {

“type” : “realtime”

},

“tuningConfig” : {

“type” : “realtime”,

“maxRowsInMemory” : “100000”,

“intermediatePersistPeriod” : “PT10M”,

“windowPeriod” : “PT10M”

}

},

“properties” : {

“task.partitions” : “3”,

“topicPattern” : “AweFormSubmit”

}

}

},

“properties” : {

“zookeeper.connect” : “localhost”,

“druid.discovery.curator.path” : “/druid/discovery”,

“druid.selectors.indexing.serviceName” : “/druid/overlord”,

“commit.periodMillis” : “15000”,

“consumer.numThreads” : “2”,

“kafka.zookeeper.connect” : “localhost”,

“kafka.group.id” : “tranquility-kafka”

}

}

``