Kafka indexing service task failing

Hey ,

I am getting the following error while running kafka indexing task. Don’t know where the issue is. Even there are no OOM exception on any node.

2016-09-13T14:54:26,746 ERROR [task-runner-0-priority-0] io.druid.indexing.overlord.ThreadPoolTaskRunner - Exception while running task[KafkaIndexTask{id=index_kafka_prism-data-1_6527924d30d09d3_coghdpjo, type=index_kafka, dataSource=prism-data-1}]
java.lang.NullPointerException
	at java.nio.ByteBuffer.wrap(ByteBuffer.java:396) ~[?:1.8.0_101]
	at io.druid.indexing.kafka.KafkaIndexTask.run(KafkaIndexTask.java:412) ~[?:?]
	at io.druid.indexing.overlord.ThreadPoolTaskRunner$ThreadPoolTaskRunnerCallable.call(ThreadPoolTaskRunner.java:436) [druid-indexing-service-0.9.1.2-SNAPSHOT.jar:0.9.1.2-SNAPSHOT]
	at io.druid.indexing.overlord.ThreadPoolTaskRunner$ThreadPoolTaskRunnerCallable.call(ThreadPoolTaskRunner.java:408) [druid-indexing-service-0.9.1.2-SNAPSHOT.jar:0.9.1.2-SNAPSHOT]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_101]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [?:1.8.0_101]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [?:1.8.0_101]
	at java.lang.Thread.run(Thread.java:745) [?:1.8.0_101]

Any suggestion what we are doing wrong and what is causing this issue.

Thanks,
Saurabh

Hey Saurabh,

I believe this would occur if you have a message with a null value. I raised this PR to fix that: https://github.com/druid-io/druid/pull/3453

In the meantime hopefully you can work around this by avoiding null values in your topic.